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

SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[0](AA_ON): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_7978a765ad_152f4665_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_7978a765ad_152f4665_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_7978a765ad_152f4665_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_7978a765ad_152f4665_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$984/0x0000000800820840@766503c1 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_7978a765ad_152f4665_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$984/0x0000000800820840@1480a645 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_7978a765ad_152f4665_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027689355, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_7978a765ad_152f4665_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027689355, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_7978a765ad_152f4665_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027689355, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_7978a765ad_152f4665_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$984/0x0000000800820840@2f23c7a9 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_7978a765ad_152f4665_v1", 1, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027689355, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_7978a765ad_152f4665_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027689355, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClas

SITWithTWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[1](true): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1

SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_a4bdc159cf_fd0b1d4b_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_a4bdc159cf_fd0b1d4b_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_a4bdc159cf_fd0b1d4b_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_a4bdc159cf_fd0b1d4b_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$531/0x00000008006a4840@16e2703a ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_a4bdc159cf_fd0b1d4b_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$531/0x00000008006a4840@5399f6dd ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_a4bdc159cf_fd0b1d4b_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027875199, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_a4bdc159cf_fd0b1d4b_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027875199, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_a4bdc159cf_fd0b1d4b_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027875200, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_a4bdc159cf_fd0b1d4b_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$531/0x00000008006a4840@256378f5 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_a4bdc159cf_fd0b1d4b_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027875200, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_a4bdc159cf_fd0b1d4b_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$531/0x00000008006a4840@e6d9cef ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataServic

TestRemoteIngestionRepairService.testIngestionRepairService: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/TestRemoteIngestionRepairService.java#L25

java.lang.AssertionError: expected [2] but found [1]

SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[0](AA_ON): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1

SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1

TestRemoteIngestionRepairService.testIngestionRepairService: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/TestRemoteIngestionRepairService.java#L25

java.lang.AssertionError: expected [2] but found [1]

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_5d290c5d77_9cc2dc6e_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_5d290c5d77_9cc2dc6e_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_5d290c5d77_9cc2dc6e_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_5d290c5d77_9cc2dc6e_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$560/546992026@1f372457 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_5d290c5d77_9cc2dc6e_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027752595, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_5d290c5d77_9cc2dc6e_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027752595, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_5d290c5d77_9cc2dc6e_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$560/546992026@62e22d4 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_5d290c5d77_9cc2dc6e_v1", 1, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027752595, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_5d290c5d77_9cc2dc6e_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$560/546992026@6f2c21d2 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_5d290c5d77_9cc2dc6e_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027752595, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_5d290c5d77_9cc2dc6e_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027752595, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.lin

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: storageMetadataService.put( "TestTopic_86f4a52a10_8460ac0f_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_86f4a52a10_8460ac0f_v1", 1 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.getLastOffset( "TestTopic_86f4a52a10_8460ac0f_v1", 2 ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49) storageMetadataService.computeStoreVersionState( "TestTopic_86f4a52a10_8460ac0f_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$258/1954777964@36137ac ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.computeStoreVersionState( "TestTopic_86f4a52a10_8460ac0f_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$258/1954777964@7c3accc1 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_86f4a52a10_8460ac0f_v1", 1, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027932110, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_86f4a52a10_8460ac0f_v1", 2, OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027932110, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_86f4a52a10_8460ac0f_v1", 2, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027932111, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.computeStoreVersionState( "TestTopic_86f4a52a10_8460ac0f_v1", com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$258/1954777964@51dc0bd7 ); -> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:34) storageMetadataService.put( "TestTopic_86f4a52a10_8460ac0f_v1", 1, OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027932111, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38) storageMetadataService.put( "TestTopic_86f4a52a10_8460ac0f_v1", 2, OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1741027932111, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}, recordTransformerClassHash=null} ); -> at com.

SITWithPWiseAndBufferAfterLeaderTest.testNotifier[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1

SITWithTWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1

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:2656)

DispatchingAvroGenericStoreClientTest.testBatchGet: clients/venice-client/src/test/java/com/linkedin/venice/fastclient/DispatchingAvroGenericStoreClientTest.java#L654

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

DispatchingAvroGenericStoreClientTest.testBatchGetToUnreachableClient: clients/venice-client/src/test/java/com/linkedin/venice/fastclient/DispatchingAvroGenericStoreClientTest.java#L1021

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]

DispatchingAvroGenericStoreClientTest.testBatchGet: clients/venice-client/src/test/java/com/linkedin/venice/fastclient/DispatchingAvroGenericStoreClientTest.java#L654

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

DispatchingAvroGenericStoreClientTest.testBatchGetToUnreachableClient: clients/venice-client/src/test/java/com/linkedin/venice/fastclient/DispatchingAvroGenericStoreClientTest.java#L1021

com.linkedin.venice.endToEnd.DaVinciClientRecordTransformerTest ► testRecordTransformer: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/DaVinciClientRecordTransformerTest.java#L178

Failed test found in: IntegrationTests_1000-artifacts/internal/venice-test-common/build/test-results/integrationTests_1000/TEST-com.linkedin.venice.endToEnd.DaVinciClientRecordTransformerTest.xml internal/venice-test-common/build/test-results/integrationTests_1000/TEST-com.linkedin.venice.endToEnd.DaVinciClientRecordTransformerTest.xml Error: java.lang.AssertionError: expected [true] but found [false]

com.linkedin.venice.fastclient.grpc.VeniceGrpcEndToEndTest ► testSingleGet: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/fastclient/grpc/VeniceGrpcEndToEndTest.java#L275

Failed test found in: IntegrationTests_1070-artifacts/internal/venice-test-common/build/test-results/integrationTests_1070/TEST-com.linkedin.venice.fastclient.grpc.VeniceGrpcEndToEndTest.xml internal/venice-test-common/build/test-results/integrationTests_1070/TEST-com.linkedin.venice.fastclient.grpc.VeniceGrpcEndToEndTest.xml Error: java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientException: java.net.SocketTimeoutException: 1000 MILLISECONDS

com.linkedin.venice.consumer.TestChangelogConsumer ► testAAIngestionWithStoreView: internal/venice-test-common/src/main/java/com/linkedin/venice/utils/TestUtils.java#L271

Failed test found in: IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml Error: java.lang.AssertionError: java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientException: java.net.SocketTimeoutException: 1000 MILLISECONDS

com.linkedin.venice.router.TestReadForApacheAsyncClient ► testRequestUsageMetric: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/router/TestRead.java#L779

Failed test found in: IntegrationTests_1090-artifacts/internal/venice-test-common/build/test-results/integrationTests_1090/TEST-com.linkedin.venice.router.TestReadForApacheAsyncClient.xml IntegrationTests_1090-artifacts/internal/venice-test-common/build/test-results/integrationTests_1090/TEST-com.linkedin.venice.router.TestReadForHttpClient5.xml internal/venice-test-common/build/test-results/integrationTests_1090/TEST-com.linkedin.venice.router.TestReadForApacheAsyncClient.xml internal/venice-test-common/build/test-results/integrationTests_1090/TEST-com.linkedin.venice.router.TestReadForHttpClient5.xml Error: java.lang.AssertionError: expected [1.0] but found [0.0]

com.linkedin.venice.router.TestReadForApacheAsyncClient ► testResourceStateLookup: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/router/TestRead.java#L717

com.linkedin.venice.router.TestReadForApacheAsyncClient ► testRouterHealthCheck: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/router/TestRead.java#L687

com.linkedin.venice.endToEnd.TestActiveActiveReplicationForIncPush ► testAAReplicationForIncPush: internal/venice-common/src/main/java/com/linkedin/venice/controllerapi/ControllerClient.java#L1511

Failed test found in: IntegrationTests_1050-artifacts/internal/venice-test-common/build/test-results/integrationTests_1050/TEST-com.linkedin.venice.endToEnd.TestActiveActiveReplicationForIncPush.xml internal/venice-test-common/build/test-results/integrationTests_1050/TEST-com.linkedin.venice.endToEnd.TestActiveActiveReplicationForIncPush.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.TestActiveActiveReplicationForIncPush.testAAReplicationForIncPush() didn't finish within the time-out 180000

com.linkedin.venice.endToEnd.TestBatchForRocksDB ► testBatchJobSnapshots[2](true): internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/TestBatch.java#L1428

Failed test found in: IntegrationTests_1230-artifacts/internal/venice-test-common/build/test-results/integrationTests_1230/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml internal/venice-test-common/build/test-results/integrationTests_1230/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml Error: java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 503, com.linkedin.alpini.router.api.RouterException: store_52486c9c26_51e37dad_v1, partition 2 is not available to serve request of type: SINGLE_GET

com.linkedin.venice.endToEnd.TestBatchForRocksDB ► testCompressingRecord[0](false, false): internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/TestBatch.java#L249

Failed test found in: IntegrationTests_1230-artifacts/internal/venice-test-common/build/test-results/integrationTests_1230/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml internal/venice-test-common/build/test-results/integrationTests_1230/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml Error: java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 503, com.linkedin.alpini.router.api.RouterException: store_535a1382d0_80aa84d3_v1, partition 2 is not available to serve request of type: SINGLE_GET

com.linkedin.venice.endToEnd.MetaSystemStoreTest ► testThinClientMetaStoreBasedRepositoryWithLargeValueSchemas: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/MetaSystemStoreTest.java#L316

Failed test found in: IntegrationTests_1500-artifacts/internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml Error: java.lang.AssertionError: Number of value schemas should be the same between meta system store and controller expected [2] but found [1]

com.linkedin.venice.endToEnd.MetaSystemStoreTest ► testThinClientMetaStoreBasedRepositoryWithLargeValueSchemas: clients/da-vinci-client/src/main/java/com/linkedin/davinci/repository/NativeMetadataRepository.java#L186

Failed test found in: IntegrationTests_1500-artifacts/internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml Error: com.linkedin.venice.exceptions.VeniceNoStoreException: Store: venice_store_76d56e2986_833bddd7 does not exist.

com.linkedin.venice.endToEnd.PushStatusStoreTest ► testIncrementalPush: clients/da-vinci-client/src/main/java/com/linkedin/davinci/client/AvroGenericDaVinciClient.java#L833

Failed test found in: IntegrationTests_1200-artifacts/internal/venice-test-common/build/test-results/integrationTests_1200/TEST-com.linkedin.venice.endToEnd.PushStatusStoreTest.xml internal/venice-test-common/build/test-results/integrationTests_1200/TEST-com.linkedin.venice.endToEnd.PushStatusStoreTest.xml Error: com.linkedin.venice.client.exceptions.VeniceClientException: Unable to start Da Vinci client, storeName=store_bb61ca7a5f_c79e9b94

com.linkedin.venice.endToEnd.DaVinciClientTest ► testBootstrapSubscription[0](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=null, largeBatchRequestSplitThreshold=100}): clients/da-vinci-client/src/main/java/com/linkedin/davinci/client/AvroGenericDaVinciClient.java#L833

com.linkedin.venice.endToEnd.DaVinciClientTest ► testObjectReuse[2](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=ObjectCacheConfig{maxCacheSize=Optional.empty, ttlInMilliseconds=Optional.empty}, largeBatch...: clients/da-vinci-client/src/main/java/com/linkedin/davinci/client/AvroGenericDaVinciClient.java#L833

com.linkedin.venice.endToEnd.DaVinciClientTest ► testReadCompressedData[0](NO_OP): clients/da-vinci-client/src/main/java/com/linkedin/davinci/client/AvroGenericDaVinciClient.java#L833

com.linkedin.venice.endToEnd.DaVinciClientTest ► testStatusReportDuringBoostrap[0](BUILT_IN): internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/integration/utils/DaVinciTestContext.java#L124

com.linkedin.venice.endToEnd.DaVinciClientTest ► testSubscribeAndUnsubscribe: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/integration/utils/DaVinciTestContext.java#L124

Failed test found in: IntegrationTests_1010-artifacts/internal/venice-test-common/build/test-results/integrationTests_1010/TEST-com.linkedin.venice.endToEnd.DaVinciClientTest.xml IntegrationTests_1010-artifacts/internal/venice-test-common/build/test-results/integrationTests_1010/TEST-com.linkedin.venice.endToEnd.DaVinciClientTest.xml internal/venice-test-common/build/test-results/integrationTests_1010/TEST-com.linkedin.venice.endToEnd.DaVinciClientTest.xml internal/venice-test-common/build/test-results/integrationTests_1010/TEST-com.linkedin.venice.endToEnd.DaVinciClientTest.xml Error: com.linkedin.venice.exceptions.VeniceException: Failed to start Da Vinci client in 10 attempts.

com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest ► testActiveActivePartialUpdateWithCompression[4](ZSTD_WITH_DICT): internal/venice-test-common/src/main/java/com/linkedin/venice/utils/TestUtils.java#L271

Failed test found in: IntegrationTests_1260-artifacts/internal/venice-test-common/build/test-results/integrationTests_1260/TEST-com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest.xml internal/venice-test-common/build/test-results/integrationTests_1260/TEST-com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest.xml Error: java.lang.AssertionError: com.linkedin.venice.exceptions.VeniceException: java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 500, com.linkedin.alpini.router.api.RouterException: Resource 'rmdChunking_5ee918dbc4_f77e6768_v1' does not exist

com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest ► testIncrementalPushPartialUpdateClassicFormat: internal/venice-test-common/src/main/java/com/linkedin/venice/utils/TestUtils.java#L500

com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest ► testWriteComputeWithHybridLeaderFollowerLargeRecord[4](false, GZIP): internal/venice-common/src/main/java/com/linkedin/venice/controllerapi/ControllerTransport.java#L169

Failed test found in: IntegrationTests_1260-artifacts/internal/venice-test-common/build/test-results/integrationTests_1260/TEST-com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest.xml internal/venice-test-common/build/test-results/integrationTests_1260/TEST-com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.PartialUpdateTest.testWriteComputeWithHybridLeaderFollowerLargeRecord() didn't finish within the time-out 180000

com.linkedin.venice.endToEnd.PartialUpdateWithParallelProcessingTest ► testActiveActivePartialUpdateWithCompression[2](GZIP): internal/venice-test-common/src/main/java/com/linkedin/venice/utils/TestUtils.java#L500

com.linkedin.venice.controller.TestHAASController ► testConcurrentClusterInitialization: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/controller/TestHAASController.java#L402

Failed test found in: IntegrationTests_1430-artifacts/internal/venice-test-common/build/test-results/integrationTests_1430/TEST-com.linkedin.venice.controller.TestHAASController.xml IntegrationTests_1430-artifacts/internal/venice-test-common/build/test-results/integrationTests_1430/TEST-com.linkedin.venice.controller.TestHAASController.xml internal/venice-test-common/build/test-results/integrationTests_1430/TEST-com.linkedin.venice.controller.TestHAASController.xml internal/venice-test-common/build/test-results/integrationTests_1430/TEST-com.linkedin.venice.controller.TestHAASController.xml Error: java.util.concurrent.ExecutionException: org.apache.helix.HelixException: State model LeaderStandby not found in the cluster STATEMODELDEFS path

com.linkedin.venice.controller.TestTopicRequestOnHybridDelete ► serverRestartOnHybridStoreKeepsVersionOnline: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/controller/TestTopicRequestOnHybridDelete.java#L144

com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository ► testDVCRequestBasedMetaRepositoryStringToNameRecordVersions: internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/TestDaVinciRequestBasedMetaRepository.java#L215

Failed test found in: IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository.xml internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository.xml Error: java.lang.AssertionError: expected [10.0] but found [9.0]

com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository ► testDVCRequestBasedMetaRepositoryStringToNameRecordVersions: internal/venice-common/src/main/java/com/linkedin/venice/controllerapi/ControllerClient.java#L1511

Failed test found in: IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository.xml internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository.testDVCRequestBasedMetaRepositoryStringToNameRecordVersions() didn't finish within the time-out 120000

com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint ► testRequestBasedStorePropertiesWithLargestKnownSchemaId: IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml#L0

Failed test found in: IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.testRequestBasedStorePropertiesWithLargestKnownSchemaId() didn't finish within the time-out 60000

com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint ► testRequestBasedStorePropertiesWithStoreChanges: IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml#L0

Failed test found in: IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.testRequestBasedStorePropertiesWithStoreChanges() didn't finish within the time-out 60000

com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint ► testRequestBasedStorePropertiesWithLargestKnownSchemaId: internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml#L0

Failed test found in: internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.testRequestBasedStorePropertiesWithLargestKnownSchemaId() didn't finish within the time-out 60000

com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint ► testRequestBasedStorePropertiesWithStoreChanges: internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml#L0

Failed test found in: internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.xml Error: org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.endToEnd.TestServerStorePropertiesEndpoint.testRequestBasedStorePropertiesWithStoreChanges() didn't finish within the time-out 60000

Integrations / UT & CodeCov (8)