fix old ut #436
pthirun
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
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
20 errors
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryFails[4](MULTI_GET_STREAMING):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryFails[4](MULTI_GET_STREAMING):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[0](SINGLE_GET, false, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[0](SINGLE_GET, false, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
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 182 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_8972e69cfa_5b3df954_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_8972e69cfa_5b3df954_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:539)
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: 802197988
);
-> 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: 802197988
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_8972e69cfa_5b3df954_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091633690},
Mock for Store, hashCode: 802197988
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_8972e69cfa_5b3df954_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091633690}
);
-> 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_8972e69cfa_5b3df954_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 496 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_bf812fab3f_bf4ccca0_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_bf812fab3f_bf4ccca0_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:539)
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: 1495428838
);
-> 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: 1495428838
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_bf812fab3f_bf4ccca0_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091872203},
Mock for Store, hashCode: 1495428838
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_bf812fab3f_bf4ccca0_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091872203}
);
-> 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_bf812fab3f_bf4ccca0_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
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 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
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_9e306b5586_a778119d_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_9e306b5586_a778119d_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:539)
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: 1905327118
);
-> 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: 1905327118
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_9e306b5586_a778119d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091722770},
Mock for Store, hashCode: 1905327118
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_9e306b5586_a778119d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091722770}
);
-> 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_9e306b5586_a778119d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
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 182 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_8972e69cfa_5b3df954_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_8972e69cfa_5b3df954_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:539)
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: 802197988
);
-> 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: 802197988
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_8972e69cfa_5b3df954_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091633690},
Mock for Store, hashCode: 802197988
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_8972e69cfa_5b3df954_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091633690}
);
-> 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_8972e69cfa_5b3df954_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 496 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_bf812fab3f_bf4ccca0_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_bf812fab3f_bf4ccca0_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:539)
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: 1495428838
);
-> 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: 1495428838
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_bf812fab3f_bf4ccca0_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091872203},
Mock for Store, hashCode: 1495428838
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_bf812fab3f_bf4ccca0_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091872203}
);
-> 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_bf812fab3f_bf4ccca0_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
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 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
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_9e306b5586_a778119d_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_9e306b5586_a778119d_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:539)
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: 1905327118
);
-> 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: 1905327118
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_9e306b5586_a778119d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091722770},
Mock for Store, hashCode: 1905327118
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_9e306b5586_a778119d_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091722770}
);
-> 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_9e306b5586_a778119d_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
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_5026964233_d316f25_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5026964233_d316f25_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: 667051743
);
-> 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: 667051743
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5026964233_d316f25_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091778216},
Mock for Store, hashCode: 667051743
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5026964233_d316f25_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091778216}
);
-> 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_5026964233_d316f25_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProcessedR
|
|
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_5026964233_d316f25_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5026964233_d316f25_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: 667051743
);
-> 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: 667051743
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5026964233_d316f25_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091778216},
Mock for Store, hashCode: 667051743
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5026964233_d316f25_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091778216}
);
-> 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_5026964233_d316f25_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProcessedR
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (53.23968) which is too far from the predictedUsage (48); delta: 0.109; maxAllowedDelta: 0.019. 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 (53.23968) which is too far from the predictedUsage (48); delta: 0.109; maxAllowedDelta: 0.019. 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:1612)
However, there were exactly 216 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_537036ea57_d464ba37_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_537036ea57_d464ba37_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: 1381538633
);
-> 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: 1381538633
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_537036ea57_d464ba37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091836806},
Mock for Store, hashCode: 1381538633
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_537036ea57_d464ba37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091836806}
);
-> 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_537036ea57_d464ba37_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
However, there were exactly 23 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
6.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.051045d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.040505d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.118582d,
1770091866005L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.037991d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.638184d,
1770091866009L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2773)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.065502d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.055695d,
1770091866020L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.k
|
|
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 216 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_537036ea57_d464ba37_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_537036ea57_d464ba37_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: 1381538633
);
-> 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: 1381538633
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_537036ea57_d464ba37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091836806},
Mock for Store, hashCode: 1381538633
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_537036ea57_d464ba37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770091836806}
);
-> 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_537036ea57_d464ba37_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
However, there were exactly 23 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
6.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.051045d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.040505d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.118582d,
1770091866005L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.037991d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.638184d,
1770091866009L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2773)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.065502d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.055695d,
1770091866020L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.k
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
Expired
|
925 KB |
sha256:02c49e0889e36a2d63081a7b0aea24d97ace148905688214478d7b1b5f1791e8
|
|
|
clients-jdk11
Expired
|
3.16 MB |
sha256:dfc1027f88814ddf554136ae1790d6bab623bbadc618088d9d0d1feb14f95423
|
|
|
clients-jdk17
Expired
|
3.21 MB |
sha256:4f82eadedeea4deb0d2321dfd47c47151618c659ab94581208d715f73dd17c2e
|
|
|
clients-jdk8
Expired
|
3.18 MB |
sha256:c3a454bde1e46c32b6aeeeaab4dca97d1e26c882815761817d494f5045852be1
|
|
|
controller-jdk11
Expired
|
2 MB |
sha256:892e16ecd872a3aca92ca434eec64a7c720c07c83aa60b4b8684cdcc2420814b
|
|
|
controller-jdk17
Expired
|
2 MB |
sha256:6400ebe5e1b50454a1e94addae1d48fe66752902e000fc8275a48b2c2d71860c
|
|
|
controller-jdk8
Expired
|
2 MB |
sha256:bfc970feda322e216a3f782d49441091f83adfa51721826fe0a9a43f758737ed
|
|
|
integrations-jdk11
Expired
|
553 KB |
sha256:d773299fbfe9977179b08b121c4b401b448f4c143d2ceab193f30306d78991c7
|
|
|
integrations-jdk17
Expired
|
561 KB |
sha256:26cd91f148d8927b3f5bdc186c25b82f39c51a6d1c245887daaa863736cc483a
|
|
|
integrations-jdk8
Expired
|
542 KB |
sha256:cf63dc80a3e428598a7b31f1f1438f1bded4ff90a306da3ba61ad44c5f453dba
|
|
|
internal-jdk11
Expired
|
4.28 MB |
sha256:6e34ff9ee8ff286f5fad15642c55d650cb3b6c52bea070732bff6c724791d635
|
|
|
internal-jdk17
Expired
|
4.29 MB |
sha256:bfea24cf6ebeeef69466479d8deab281f0a56e873fcc683316a74a54bd222b14
|
|
|
internal-jdk8
Expired
|
4.26 MB |
sha256:30a46ab6f2ea06bd5b6c7193051c61326831a237c48b8869c6a98fb3b69778af
|
|
|
router-jdk11
Expired
|
765 KB |
sha256:b760d041e85e35c8bbc002d187b2102eb35fb5a19d2b2eb94fa94b2dc9691fa9
|
|
|
router-jdk17
Expired
|
770 KB |
sha256:4ced14735c3503d1b8d81cd584bf044ca850b056511988b39d6d55794f894652
|
|
|
router-jdk8
Expired
|
758 KB |
sha256:6c9d1b96e9df4cdf512d14cd20fef0a98c5b0d3f0de68273a5b5faaa74eda514
|
|
|
server-jdk11
Expired
|
10.3 MB |
sha256:fdb7f202827d0a5dbe851cb6a50a1e54736f2881ced6376dcb40b801bcce81d7
|
|
|
server-jdk17
Expired
|
10.7 MB |
sha256:0ede87bdeaec4f866b1740e07ffc8fce54ecbc11d169aea15674a8947781b311
|
|
|
server-jdk8
Expired
|
10.2 MB |
sha256:e0334141084d87749856cbf81734c02fddbaf0e85d40112d51280fe22d85fbd4
|
|