Process completed with exit code 1.

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_63f7fb5073_b70643d1_v1", 2, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1626) Actual invocations have different arguments: storageMetadataService.getLastOffset( "TestTopic_63f7fb5073_b70643d1_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_63f7fb5073_b70643d1_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_63f7fb5073_b70643d1_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$987/0x00000008007eac40@4cb5962c ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_63f7fb5073_b70643d1_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582458010, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_63f7fb5073_b70643d1_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582458011, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_63f7fb5073_b70643d1_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$987/0x00000008007eac40@44de0da4 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_63f7fb5073_b70643d1_v1", 1, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582458011, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_63f7fb5073_b70643d1_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$987/0x00000008007eac40@139f293f ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_63f7fb5073_b70643d1_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582458010, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_63f7fb5073_b70643d1_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582458011, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClas

org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:499) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2637)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_67645eff31_1df5a500", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_67645eff31_1df5a500", 1, 4.0d, 1739582472784L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_67645eff31_1df5a500", 1, -4.43704054454E11d, 1739582472785L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_67645eff31_1df5a500", 1, 1.0d, 1739582472895L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_67ace0c64f_f9ad1b63", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_67ace0c64f_f9ad1b63", 1, 4.0d, 1739582473974L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_67ace0c64f_f9ad1b63", 1, -4.44892821117E11d, 1739582473975L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_67ace0c64f_f9ad1b63", 1, 1.0d, 1739582474086L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_797a47e403_cf1256ad_v1", 1, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1624) Actual invocations have different arguments: storageMetadataService.getLastOffset( "TestTopic_797a47e403_cf1256ad_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_797a47e403_cf1256ad_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_797a47e403_cf1256ad_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@325d3477 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_797a47e403_cf1256ad_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@58905e25 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_797a47e403_cf1256ad_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582559775, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_797a47e403_cf1256ad_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582559775, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_797a47e403_cf1256ad_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582559786, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_797a47e403_cf1256ad_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582559787, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_797a47e403_cf1256ad_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@4e7c3d05 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_797a47e403_cf1256ad_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@e3b9817 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataServic

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_7d482c350a_19de2250_v1", 2, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1626) Actual invocations have different arguments: storageMetadataService.getLastOffset( "TestTopic_7d482c350a_19de2250_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_7d482c350a_19de2250_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_7d482c350a_19de2250_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@3f6beaf2 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_7d482c350a_19de2250_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@4de5ceac ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_7d482c350a_19de2250_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582566798, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_7d482c350a_19de2250_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582566809, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_7d482c350a_19de2250_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$536/0x000000080069c040@2c409522 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_7d482c350a_19de2250_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582566798, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_7d482c350a_19de2250_v1", 1, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582566809, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_7d482c350a_19de2250_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582566809, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClas

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_7de7f023df_49493300", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_7de7f023df_49493300", 1, 16.0d, 1739582570041L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_7de7f023df_49493300", 1, -5.40868781691E11d, 1739582570063L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_7de7f023df_49493300", 1, 1.0d, 1739582570178L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_7e5360c274_7de5fa97", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_7e5360c274_7de5fa97", 1, 18.0d, 1739582571244L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_7e5360c274_7de5fa97", 1, -5.42066091233E11d, 1739582571246L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_7e5360c274_7de5fa97", 1, 1.0d, 1739582571249L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_883fef3ef4_8a7ee330_v1", 2, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1626) Actual invocations have different arguments: storageMetadataService.getLastOffset( "TestTopic_883fef3ef4_8a7ee330_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_883fef3ef4_8a7ee330_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_883fef3ef4_8a7ee330_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$537/0x000000080069c440@6d22a330 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_883fef3ef4_8a7ee330_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$537/0x000000080069c440@5233d990 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_883fef3ef4_8a7ee330_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582613868, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_883fef3ef4_8a7ee330_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582613874, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_883fef3ef4_8a7ee330_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$537/0x000000080069c440@3aff4cb2 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_883fef3ef4_8a7ee330_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582613868, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_883fef3ef4_8a7ee330_v1", 1, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582613874, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_883fef3ef4_8a7ee330_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1739582613874, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClas

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8893d83ab6_96362ab9", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_8893d83ab6_96362ab9", 1, 13.0d, 1739582615776L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_8893d83ab6_96362ab9", 1, -5.86560060069E11d, 1739582615797L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8893d83ab6_96362ab9", 1, 1.0d, 1739582615907L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

Process completed with exit code 1.

Process completed with exit code 1.

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_722d3e8b98_cc7d7af0", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_722d3e8b98_cc7d7af0", 1, 3.0d, 1739582545951L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_722d3e8b98_cc7d7af0", 1, -4.89972311333E11d, 1739582545953L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_722d3e8b98_cc7d7af0", 1, 1.0d, 1739582546055L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_727568ecec_6f2225e8", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_727568ecec_6f2225e8", 1, 9.0d, 1739582547163L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_727568ecec_6f2225e8", 1, -4.91185305507E11d, 1739582547171L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_727568ecec_6f2225e8", 1, 1.0d, 1739582547277L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8265c9802d_98813006", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_8265c9802d_98813006", 1, 36.0d, 1739582625687L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_8265c9802d_98813006", 1, -5.70832895409E11d, 1739582626955L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8265c9802d_98813006", 1, 1.0d, 1739582627159L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_855fde6db8_9574cf22", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_855fde6db8_9574cf22", 1, 9.0d, 1739582628609L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_855fde6db8_9574cf22", 1, -5.7257142018E11d, 1739582628635L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_855fde6db8_9574cf22", 1, 1.0d, 1739582628745L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8b2fdcce42_a656574b", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_8b2fdcce42_a656574b", 1, 33.0d, 1739582663949L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_8b2fdcce42_a656574b", 1, -6.09192371602E11d, 1739582665328L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8b2fdcce42_a656574b", 1, 1.0d, 1739582665511L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8e495763ee_2c75ab55", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_8e495763ee_2c75ab55", 1, 8.0d, 1739582666880L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_8e495763ee_2c75ab55", 1, -6.10802011521E11d, 1739582666903L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8e495763ee_2c75ab55", 1, 1.0d, 1739582667025L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9399c78f56_ac89054a", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_9399c78f56_ac89054a", 1, 38.0d, 1739582699961L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_9399c78f56_ac89054a", 1, -6.44980899347E11d, 1739582701165L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9399c78f56_ac89054a", 1, 1.0d, 1739582701343L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_96a3fd8852_fe711499", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_96a3fd8852_fe711499", 1, 9.0d, 1739582702817L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_96a3fd8852_fe711499", 1, -6.46709262566E11d, 1739582702852L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_96a3fd8852_fe711499", 1, 1.0d, 1739582702975L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9beb8f65e8_228b6e23", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_9beb8f65e8_228b6e23", 1, 37.0d, 1739582735588L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_9beb8f65e8_228b6e23", 1, -6.80745254778E11d, 1739582736983L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9beb8f65e8_228b6e23", 1, 1.0d, 1739582737197L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9efcd287f8_ee24bcd6", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_9efcd287f8_ee24bcd6", 1, 9.0d, 1739582738568L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_9efcd287f8_ee24bcd6", 1, -6.82423985624E11d, 1739582738597L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9efcd287f8_ee24bcd6", 1, 1.0d, 1739582738708L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClientTest.testBatchGet() didn't finish within the time-out 10000

java.lang.AssertionError: Cannot invoke "com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.batchGet(com.linkedin.venice.fastclient.BatchGetRequestContext, java.util.Set)" because "this.statsAvroGenericStoreClient" is null expected [true] but found [false]

org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClientTest.testBatchGet() didn't finish within the time-out 10000

java.lang.AssertionError: Cannot invoke "com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.batchGet(com.linkedin.venice.fastclient.BatchGetRequestContext, java.util.Set)" because "this.statsAvroGenericStoreClient" is null expected [true] but found [false]

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_78880c669d_30e9a5b0", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_78880c669d_30e9a5b0", 1, 6.0d, 1739582564399L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_78880c669d_30e9a5b0", 1, -5.17227584608E11d, 1739582564403L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_78880c669d_30e9a5b0", 1, 1.0d, 1739582564508L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_78d67f258f_f86ddb96", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_78d67f258f_f86ddb96", 1, 6.0d, 1739582565736L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_78d67f258f_f86ddb96", 1, -5.18563796418E11d, 1739582565739L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_78d67f258f_f86ddb96", 1, 1.0d, 1739582565858L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8a657032b0_73ffaf00", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_8a657032b0_73ffaf00", 1, 27.0d, 1739582659191L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(Unknown Source) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_8a657032b0_73ffaf00", 1, -6.15674849792E11d, 1739582662982L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8a657032b0_73ffaf00", 1, 1.0d, 1739582663146L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8fca82f5ab_297aac4f", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_8fca82f5ab_297aac4f", 1, 9.0d, 1739582664624L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_8fca82f5ab_297aac4f", 1, -6.17467743521E11d, 1739582664749L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_8fca82f5ab_297aac4f", 1, 1.0d, 1739582664858L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_96928ae20a_c8e9ba0", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_96928ae20a_c8e9ba0", 1, 27.0d, 1739582709300L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(Unknown Source) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_96928ae20a_c8e9ba0", 1, -6.65962900273E11d, 1739582713319L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_96928ae20a_c8e9ba0", 1, 1.0d, 1739582713484L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9b83e9c15a_b7a1563d", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_9b83e9c15a_b7a1563d", 1, 9.0d, 1739582714959L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_9b83e9c15a_b7a1563d", 1, -6.67725691721E11d, 1739582715052L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_9b83e9c15a_b7a1563d", 1, 1.0d, 1739582715165L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_a1f9b93b15_e08bc654", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_a1f9b93b15_e08bc654", 1, 50.0d, 1739582758806L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(Unknown Source) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_a1f9b93b15_e08bc654", 1, -7.15733791463E11d, 1739582763149L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_a1f9b93b15_e08bc654", 1, 1.0d, 1739582763314L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_a7205b0067_c6bfb9e9", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_a7205b0067_c6bfb9e9", 1, 11.0d, 1739582764827L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_a7205b0067_c6bfb9e9", 1, -7.17541529164E11d, 1739582764922L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_a7205b0067_c6bfb9e9", 1, 1.0d, 1739582765040L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_ad0d92a001_e167eac3", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_ad0d92a001_e167eac3", 1, 34.0d, 1739582805640L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(Unknown Source) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_ad0d92a001_e167eac3", 1, -7.62335630403E11d, 1739582809798L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_ad0d92a001_e167eac3", 1, 1.0d, 1739582809962L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_b1fc99cdaf_b6e78695", <any integer>, <any long>, <any long> ); -> at com.linkedin.davinci.stats.AggVersionedDaVinciRecordTransformerStats.recordTransformerPutError(AggVersionedDaVinciRecordTransformerStats.java:60) Actual invocations have different arguments: aggVersionedDaVinciRecordTransformerStats.recordTransformerOnStartVersionIngestionLatency( "TestTopic_b1fc99cdaf_b6e78695", 1, 9.0d, 1739582811488L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.<init>(StoreIngestionTask.java:513) aggVersionedDaVinciRecordTransformerStats.recordTransformerOnRecoveryLatency( "TestTopic_b1fc99cdaf_b6e78695", 1, -7.64191060427E11d, 1739582811624L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:662) aggVersionedDaVinciRecordTransformerStats.recordTransformerPutError( "TestTopic_b1fc99cdaf_b6e78695", 1, 1.0d, 1739582811736L ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processKafkaDataMessage(StoreIngestionTask.java:3807)

Process completed with exit code 1.