Skip to content
AnalyseStatiqueEtTestsUnitaires

Restore PR review changes: use concise message names and repeated Sto… #438

Sign in to view logs

Restore PR review changes: use concise message names and repeated Sto…

Restore PR review changes: use concise message names and repeated Sto… #438

Triggered via push February 3, 2026 02:12
@pthirunpthirun
pushed 12aaa8f
controller-grpc-migration-cluster-health-stores
Status Failure
Total duration 1h 9m 27s
Artifacts 19

VeniceCI-StaticAnalysisAndUnitTests.yml

on: push
Matrix: Clients / UT & CodeCov
Matrix: Controller / UT & CodeCov
Matrix: Integrations / UT & CodeCov
Matrix: Internal / UT & CodeCov
Matrix: Router / UT & CodeCov
Matrix: Server / UT & CodeCov
Matrix: StaticAnalysis
ValidateGradleWrapper
9s
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
2s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

21 errors
StaticAnalysis (17)
Process completed with exit code 1.
InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2402339008; memoryAllocatedAfterInstantiations: 2396707520; memoryAllocatedByInstantiations: -5631488; 3 attempts left.
InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2402339008; memoryAllocatedAfterInstantiations: 2396707520; memoryAllocatedByInstantiations: -5631488; 3 attempts left.
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L144
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.venice.controller.TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl(TestVeniceParentHelixAdminWithAcl.java:144) E.g. thenReturn() may be missing. Examples of correct stubbing: when(mock.isOk()).thenReturn(true); when(mock.isOk()).thenThrow(exception); doThrow(exception).when(mock).someVoidMethod(); Hints: 1. missing thenReturn() 2. you are trying to stub a final method, which is not supported 3. you are stubbing the behaviour of another mock inside before 'thenReturn' instruction is completed
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L144
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.venice.controller.TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl(TestVeniceParentHelixAdminWithAcl.java:144) E.g. thenReturn() may be missing. Examples of correct stubbing: when(mock.isOk()).thenReturn(true); when(mock.isOk()).thenThrow(exception); doThrow(exception).when(mock).someVoidMethod(); Hints: 1. missing thenReturn() 2. you are trying to stub a final method, which is not supported 3. you are stubbing the behaviour of another mock inside before 'thenReturn' instruction is completed
Router / UT & CodeCov (17)
Process completed with exit code 1.
Router / UT & CodeCov (11)
Process completed with exit code 1.
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios: internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios: internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
Router / UT & CodeCov (8)
Process completed with exit code 1.
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testResubscribeAfterRoleChange: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: activeActiveStoreIngestionTask.resubscribeForAllPartitions(); Wanted *at least* 4 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:759) But was 3 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1713) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1713) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1713)
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51b3243d10_3ed72c5c_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51b3243d10_3ed72c5c_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 399254453 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 399254453 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51b3243d10_3ed72c5c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088352792}, Mock for Store, hashCode: 399254453 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51b3243d10_3ed72c5c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088352792} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_51b3243d10_3ed72c5c_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testResubscribeAfterRoleChange: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: activeActiveStoreIngestionTask.resubscribeForAllPartitions(); Wanted *at least* 4 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resubscribeForAllPartitions(StoreIngestionTask.java:759) But was 3 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1713) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1713) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1713)
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51b3243d10_3ed72c5c_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51b3243d10_3ed72c5c_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 399254453 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 399254453 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51b3243d10_3ed72c5c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088352792}, Mock for Store, hashCode: 399254453 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51b3243d10_3ed72c5c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088352792} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_51b3243d10_3ed72c5c_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b7fd7fd8d_c04300e9_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b7fd7fd8d_c04300e9_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 497381490 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 497381490 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b7fd7fd8d_c04300e9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088327384}, Mock for Store, hashCode: 497381490 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b7fd7fd8d_c04300e9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088327384} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4b7fd7fd8d_c04300e9_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 3 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 2 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: abstractStorageEngine.put( 1, [(byte) 0x01, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x31, (byte) 0x5F, (byte) 0x31, (byte) 0x65, (byte) 0x66, (byte) 0x34, (byte) 0x62, (byte) 0x33, (byte) 0x64, (byte) 0x34, (byte) 0x31, (byte) 0x30, (byte) 0x5F, (byte) 0x66, (byte) 0x33, (byte) 0x34, (byte) 0x33, (byte) 0x63, (byte) 0x32, (byte) 0x31, (byte) 0x36], java.nio.HeapByteBuffer[pos=0 lim=17 cap=17] ); Wanted 2 times: -> at com.linkedin.davinci.store.AbstractStorageEngine.put(AbstractStorageEngine.java:478) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39)
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b7fd7fd8d_c04300e9_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4b7fd7fd8d_c04300e9_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 497381490 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 497381490 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b7fd7fd8d_c04300e9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088327384}, Mock for Store, hashCode: 497381490 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b7fd7fd8d_c04300e9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770088327384} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4b7fd7fd8d_c04300e9_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 3 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 2 times: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: abstractStorageEngine.put( 1, [(byte) 0x01, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x31, (byte) 0x5F, (byte) 0x31, (byte) 0x65, (byte) 0x66, (byte) 0x34, (byte) 0x62, (byte) 0x33, (byte) 0x64, (byte) 0x34, (byte) 0x31, (byte) 0x30, (byte) 0x5F, (byte) 0x66, (byte) 0x33, (byte) 0x34, (byte) 0x33, (byte) 0x63, (byte) 0x32, (byte) 0x31, (byte) 0x36], java.nio.HeapByteBuffer[pos=0 lim=17 cap=17] ); Wanted 2 times: -> at com.linkedin.davinci.store.AbstractStorageEngine.put(AbstractStorageEngine.java:478) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39)
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis Expired
828 KB
sha256:0d79e13acffce0efbf65af2fbbcee2cacd8f2a0a47085a3e76394edfee8858bc
clients-jdk11 Expired
3.17 MB
sha256:f1819fb3c4dc0e16ccb868482a0a4153eb5053cc14efd4fe7a832e17ea7d6d4c
clients-jdk17 Expired
3.2 MB
sha256:97f97bac296ca65425b10f3e1fb25d4321aad826c331a8e69d1f477fbc97d722
clients-jdk8 Expired
3.17 MB
sha256:d4757a25d534071b2432babf4c5d8758b22e309f46c9a89e4da03e27396273d7
controller-jdk11 Expired
2 MB
sha256:54ff5453825b2e44261b06706b66a47107f094d36471c42b10aaaf3c6b78acf9
controller-jdk17 Expired
1.98 MB
sha256:1467cd28f1430cfff4d8b6751c35473c66205e45bb29dd9a0936c3f7450eeece
controller-jdk8 Expired
1.98 MB
sha256:a019d82756dce7d4430a61af27d90914d89d67b51dd91f7ed63f29e3d6e163f6
integrations-jdk11 Expired
544 KB
sha256:2d3796e606ab74e867cefa3fdf7e451d5d1e1cb5cf636b08affb9366d4c6ab85
integrations-jdk17 Expired
554 KB
sha256:2e4929a873dcb5a5e0b708bee3ce84c7560b84a4ee41b414804050cf5d767007
integrations-jdk8 Expired
535 KB
sha256:645ef9fef5124dd3be37b1cc8cbc4e52b03167922c0350d88d3c5aecd342222a
internal-jdk11 Expired
4.29 MB
sha256:df5018427e2af3d8cc0b3a802161f85e760289a4b8a6b8ede2c55fc604e88930
internal-jdk17 Expired
4.3 MB
sha256:11d6db13597010081dc8eac3279312d1c020519eaa7ef5db3492943c877f77e0
internal-jdk8 Expired
4.27 MB
sha256:553dbcfb5b3b343160c46240a4deb9f40497f7c6877d4f11f9e42eaf21106083
router-jdk11 Expired
765 KB
sha256:d947b12b82016df7536adf0684e4c93bdc1505a198e820a0916c491ec0fd57b5
router-jdk17 Expired
769 KB
sha256:88947c5a9625d37a4c7940af2bd06ad3bd3ebc14e66849e0f719d955e964b340
router-jdk8 Expired
757 KB
sha256:b06d8f6ab885c4dbbaadd061a226b24d505735dfbaa1a693d85d2bf004971f28
server-jdk11 Expired
10.4 MB
sha256:a4f84bcca7a62971da1cd8e199c74f8ec2d667dd64c5b65c90fcd8e150fef04a
server-jdk17 Expired
10.6 MB
sha256:7afdf458d328fc4b80405620e0dbe1f18c9ffbd3b290454fa34e33195efafff0
server-jdk8 Expired
10.3 MB
sha256:a8a15df4d5b854fe541a301602be8c62bf00aab4fdb7f859bfba9e46f5a6cb35