Skip to content
AnalyseStatiqueEtTestsUnitaires

Fix getRepushInfo to return NOT_FOUND for non-existent stores #437

Sign in to view logs

Fix getRepushInfo to return NOT_FOUND for non-existent stores

Fix getRepushInfo to return NOT_FOUND for non-existent stores #437

Triggered via push February 3, 2026 01:59
@pthirunpthirun
pushed 0cc38ce
controller-grpc-migration-get-repush-info
Status Success
Total duration 1h 13m 10s
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
0s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

20 errors
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 336 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_895e2a89b1_13fea1b1_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_895e2a89b1_13fea1b1_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: 1896973423 ); -> 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: 1896973423 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_895e2a89b1_13fea1b1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085525718}, Mock for Store, hashCode: 1896973423 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_895e2a89b1_13fea1b1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085525718} ); -> 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_895e2a89b1_13fea1b1_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:1612) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7fa3a79232_512679bd_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7fa3a79232_512679bd_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: 51925383 ); -> 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: 51925383 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7fa3a79232_512679bd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085483943}, Mock for Store, hashCode: 51925383 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7fa3a79232_512679bd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085483943} ); -> 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_7fa3a79232_512679bd_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProcesse
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
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 276 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_95ff2440aa_7ac4f53d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_95ff2440aa_7ac4f53d_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: 367236519 ); -> 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: 367236519 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_95ff2440aa_7ac4f53d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085579948}, Mock for Store, hashCode: 367236519 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_95ff2440aa_7ac4f53d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085579948} ); -> 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_95ff2440aa_7ac4f53d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): 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 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
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 336 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_895e2a89b1_13fea1b1_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_895e2a89b1_13fea1b1_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: 1896973423 ); -> 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: 1896973423 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_895e2a89b1_13fea1b1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085525718}, Mock for Store, hashCode: 1896973423 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_895e2a89b1_13fea1b1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085525718} ); -> 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_895e2a89b1_13fea1b1_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:1612) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7fa3a79232_512679bd_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7fa3a79232_512679bd_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: 51925383 ); -> 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: 51925383 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7fa3a79232_512679bd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085483943}, Mock for Store, hashCode: 51925383 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7fa3a79232_512679bd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085483943} ); -> 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_7fa3a79232_512679bd_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProcesse
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
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 276 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_95ff2440aa_7ac4f53d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_95ff2440aa_7ac4f53d_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: 367236519 ); -> 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: 367236519 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_95ff2440aa_7ac4f53d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085579948}, Mock for Store, hashCode: 367236519 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_95ff2440aa_7ac4f53d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085579948} ); -> 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_95ff2440aa_7ac4f53d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): 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 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
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 396 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7c98bd6d65_61bf6b1d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7c98bd6d65_61bf6b1d_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: 633419321 ); -> 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: 633419321 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7c98bd6d65_61bf6b1d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085837836}, Mock for Store, hashCode: 633419321 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7c98bd6d65_61bf6b1d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085837836} ); -> 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_7c98bd6d65_61bf6b1d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
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 216 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5dd74f00b1_1038787e_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5dd74f00b1_1038787e_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: 499819588 ); -> 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: 499819588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5dd74f00b1_1038787e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085700522}, Mock for Store, hashCode: 499819588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5dd74f00b1_1038787e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085700522} ); -> 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_5dd74f00b1_1038787e_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
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 396 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7c98bd6d65_61bf6b1d_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_7c98bd6d65_61bf6b1d_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: 633419321 ); -> 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: 633419321 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7c98bd6d65_61bf6b1d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085837836}, Mock for Store, hashCode: 633419321 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_7c98bd6d65_61bf6b1d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085837836} ); -> 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_7c98bd6d65_61bf6b1d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
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 216 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5dd74f00b1_1038787e_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5dd74f00b1_1038787e_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: 499819588 ); -> 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: 499819588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5dd74f00b1_1038787e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085700522}, Mock for Store, hashCode: 499819588 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5dd74f00b1_1038787e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770085700522} ); -> 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_5dd74f00b1_1038787e_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (42.61824) which is too far from the predictedUsage (40); delta: 0.065; maxAllowedDelta: 0.023. 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 (42.61824) which is too far from the predictedUsage (40); delta: 0.065; maxAllowedDelta: 0.023. No more 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
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

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis Expired
926 KB
sha256:0ff02b3cf8ef0c2457388fe9d48800f33a50858f9e97416ad62431897fcf7787
clients-jdk11 Expired
3.2 MB
sha256:307da5b2d11bcb387927e22c3190893ef4151606a3a9516a604c4ebb97f75ee5
clients-jdk17 Expired
3.19 MB
sha256:8035284e3f60c7e6be3dd68745ed5865d90888d26cd71dbaae882e1dfaf1108b
clients-jdk8 Expired
3.16 MB
sha256:cb6a7d82e3e329264f015629c56a975fb70bda8b20b99d0c64bf467f5439c323
controller-jdk11 Expired
1.99 MB
sha256:624c18533690a52f60c5c187f3460d9fe8c6f63d17628c3bd707e9609d58da2a
controller-jdk17 Expired
1.98 MB
sha256:6fdc3cbffc6ed6f8e507fec19f0175dd9e38232674660f7958e40bfe50482cd4
controller-jdk8 Expired
1.99 MB
sha256:9fd70f86272f6e2d23e0a1f7be02582e32f234ecde3d5cf9ef621d74858e5639
integrations-jdk11 Expired
551 KB
sha256:415767221e58a323854fdb666b5b0d0b004d80e673ad0910cf242181ca16b911
integrations-jdk17 Expired
560 KB
sha256:194b5ca365bc9fd3e105a3108121635e84e7ac9661e05a8cb91e4ee151ba5edf
integrations-jdk8 Expired
536 KB
sha256:20ce6fee55b6232baeb585408fc14a8cebeae9dbbbfc92f632febc18146f31da
internal-jdk11 Expired
4.31 MB
sha256:db12691fece72ed422c3deacbb0a174792e43346eaabbb9be24edaf5458a4b3d
internal-jdk17 Expired
4.32 MB
sha256:ca3280ae7f1160843db97e5f14ee9fb24f7a9f55f09bd5b249961172fba1962e
internal-jdk8 Expired
4.3 MB
sha256:edcfd8af53460caaa16ffd5f6dafa74ad090777a9f03dadd70cd3e256ea3fe84
router-jdk11 Expired
767 KB
sha256:f906bcbac4f39485a6d3c47506585037cc84c52687cbdd81720a3965240cc745
router-jdk17 Expired
771 KB
sha256:5b2105a5e3e08aa68f3d9a39d3ddf41ffc09ce13560c9e7606a4cc8939a9aaeb
router-jdk8 Expired
758 KB
sha256:6e31cdbae33bf854065fd1c3aefd1b738c54f417bc682011a069c3a390a25a91
server-jdk11 Expired
10.4 MB
sha256:8f856f326470c074ebe2c52ae0b7c4ccef477ef156c0f7ed16e7bfa0539c822e
server-jdk17 Expired
10.5 MB
sha256:50ee982cc38f96c7c7de10c27a83bb2d0a393be146403ae886424dc5bc323dbb
server-jdk8 Expired
10.3 MB
sha256:8340141d5a2dced7df63abced048a35b7031fc71584c08eca053b74d7e43dce5