java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (3.29788) which is too far from the predictedUsage (40); delta: 0.918; maxAllowedDelta: 0.303. No more attempts left.

InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49

java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (3.29788) which is too far from the predictedUsage (40); delta: 0.918; maxAllowedDelta: 0.303. No more attempts left.

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:1613) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5810483402_bae5fd1a_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5810483402_bae5fd1a_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1127252887 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1127252887 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5810483402_bae5fd1a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834646986}, Mock for Store, hashCode: 1127252887 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5810483402_bae5fd1a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834646986} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5810483402_bae5fd1a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr

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:1613) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5bccaeac8a_e3828cff_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5bccaeac8a_e3828cff_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 525128588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 525128588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5bccaeac8a_e3828cff_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834662976}, Mock for Store, hashCode: 525128588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5bccaeac8a_e3828cff_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834662976} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5bccaeac8a_e3828cff_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce

SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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:1613) However, there were exactly 336 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_58304f1d01_81e5900a_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_58304f1d01_81e5900a_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1304591647 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1304591647 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_58304f1d01_81e5900a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834647546}, Mock for Store, hashCode: 1304591647 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_58304f1d01_81e5900a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834647546} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_58304f1d01_81e5900a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr

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:1613) However, there were exactly 256 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5bccaeac8a_e3828cff_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5bccaeac8a_e3828cff_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 525128588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 525128588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5bccaeac8a_e3828cff_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834662976}, Mock for Store, hashCode: 525128588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5bccaeac8a_e3828cff_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834662976} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5bccaeac8a_e3828cff_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce

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:1613) However, there were exactly 336 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_58304f1d01_81e5900a_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_58304f1d01_81e5900a_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1304591647 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1304591647 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_58304f1d01_81e5900a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834647546}, Mock for Store, hashCode: 1304591647 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_58304f1d01_81e5900a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834647546} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_58304f1d01_81e5900a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr

SITWithSAwarePWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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:1613) However, there were exactly 516 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_85ba8cd262_fde94e7d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_85ba8cd262_fde94e7d_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1459692379 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1459692379 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_85ba8cd262_fde94e7d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834872215}, Mock for Store, hashCode: 1459692379 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_85ba8cd262_fde94e7d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834872215} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_85ba8cd262_fde94e7d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

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:1613) However, there were exactly 212 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5950eda3a3_ca49cb8f_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5950eda3a3_ca49cb8f_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1426135308 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1426135308 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5950eda3a3_ca49cb8f_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834671770}, Mock for Store, hashCode: 1426135308 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5950eda3a3_ca49cb8f_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834671770} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5950eda3a3_ca49cb8f_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

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

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

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:1613) However, there were exactly 516 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_85ba8cd262_fde94e7d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_85ba8cd262_fde94e7d_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1459692379 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1459692379 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_85ba8cd262_fde94e7d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834872215}, Mock for Store, hashCode: 1459692379 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_85ba8cd262_fde94e7d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834872215} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_85ba8cd262_fde94e7d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

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:1613) However, there were exactly 212 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5950eda3a3_ca49cb8f_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5950eda3a3_ca49cb8f_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:4537) 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:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1426135308 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1426135308 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5950eda3a3_ca49cb8f_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834671770}, Mock for Store, hashCode: 1426135308 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5950eda3a3_ca49cb8f_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834671770} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5950eda3a3_ca49cb8f_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

SITWithSAwarePWiseAndBufferAfterLeaderTest.methodSetUp: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue: 'recordTotalPollRequestLatency' is a *void method* and it *cannot* be stubbed with a *return value*! Voids are usually stubbed with Throwables: doThrow(exception).when(mock).someVoidMethod(); If you need to set the void method to do nothing you can use: doNothing().when(mock).someVoidMethod(); For more information, check out the javadocs for Mockito.doNothing(). *** If you're unsure why you're getting above error read on. Due to the nature of the syntax above problem might occur because: 1. The method you are trying to stub is *overloaded*. Make sure you are calling the right overloaded version. 2. Somewhere in your test you are stubbing *final methods*. Sorry, Mockito does not verify/stub final methods. 3. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies - - with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method. 4. Mocking methods declared on non-public parent classes is not supported.

SITWithSAwarePWiseAndBufferAfterLeaderTest.testResubscribeAfterRoleChange: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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:1714) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1714) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.refreshIngestionContextIfChanged(StoreIngestionTask.java:1714)

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:1613) However, there were exactly 496 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7a9b9613d6_c691ee1c_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7a9b9613d6_c691ee1c_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:4537) 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:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1044665461 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1044665461 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7a9b9613d6_c691ee1c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834804073}, Mock for Store, hashCode: 1044665461 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7a9b9613d6_c691ee1c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834804073} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_7a9b9613d6_c691ee1c_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

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:1613) However, there were exactly 182 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51f891309d_b7aa9628_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51f891309d_b7aa9628_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:4537) 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:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 796069413 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 796069413 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51f891309d_b7aa9628_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834620316}, Mock for Store, hashCode: 796069413 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51f891309d_b7aa9628_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834620316} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_51f891309d_b7aa9628_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l

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

SITWithSAwarePWiseAndBufferAfterLeaderTest.methodCleanUp: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue: 'recordTotalAvgPartitionsPerConsumer' is a *void method* and it *cannot* be stubbed with a *return value*! Voids are usually stubbed with Throwables: doThrow(exception).when(mock).someVoidMethod(); If you need to set the void method to do nothing you can use: doNothing().when(mock).someVoidMethod(); For more information, check out the javadocs for Mockito.doNothing(). *** If you're unsure why you're getting above error read on. Due to the nature of the syntax above problem might occur because: 1. The method you are trying to stub is *overloaded*. Make sure you are calling the right overloaded version. 2. Somewhere in your test you are stubbing *final methods*. Sorry, Mockito does not verify/stub final methods. 3. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies - - with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method. 4. Mocking methods declared on non-public parent classes is not supported.

SITWithSAwarePWiseAndBufferAfterLeaderTest.methodSetUp: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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:1613) However, there were exactly 496 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7a9b9613d6_c691ee1c_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7a9b9613d6_c691ee1c_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:4537) 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:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1044665461 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1044665461 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7a9b9613d6_c691ee1c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834804073}, Mock for Store, hashCode: 1044665461 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7a9b9613d6_c691ee1c_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834804073} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_7a9b9613d6_c691ee1c_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}

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:1613) However, there were exactly 182 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51f891309d_b7aa9628_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_51f891309d_b7aa9628_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:4537) 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:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1779) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4537) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 796069413 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5291) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5292) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 796069413 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1784) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51f891309d_b7aa9628_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834620316}, Mock for Store, hashCode: 796069413 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2123) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_51f891309d_b7aa9628_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767834620316} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2313) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5065) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_51f891309d_b7aa9628_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l

Integrations / UT & CodeCov (11)