Add integration tests for getRepushInfo gRPC endpoint #427
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
10s
StaticAnalysisAndUnitTestsFailureAlert
3s
Annotations
54 errors
|
StaticAnalysis (17)
Process completed with exit code 1.
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
Controller / UT & CodeCov (11)
Process completed with exit code 1.
|
|
Router / UT & CodeCov (11)
Process completed with exit code 1.
|
|
Router / UT & CodeCov (8)
Process completed with exit code 1.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 256 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d36c2a0d7a_7a4e4d2a_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d36c2a0d7a_7a4e4d2a_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: 491383919
);
-> 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: 491383919
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d36c2a0d7a_7a4e4d2a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824840876},
Mock for Store, hashCode: 491383919
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d36c2a0d7a_7a4e4d2a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824840876}
);
-> 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_d36c2a0d7a_7a4e4d2a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_e0021761eb_72dfa406_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_e0021761eb_72dfa406_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: 2028630624
);
-> 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: 2028630624
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_e0021761eb_72dfa406_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824894945},
Mock for Store, hashCode: 2028630624
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_e0021761eb_72dfa406_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824894945}
);
-> 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_e0021761eb_72dfa406_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
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)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 256 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d6c1df055f_aa92deb9_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d6c1df055f_aa92deb9_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: 817424627
);
-> 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: 817424627
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d6c1df055f_aa92deb9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824855185},
Mock for Store, hashCode: 817424627
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d6c1df055f_aa92deb9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824855185}
);
-> 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_d6c1df055f_aa92deb9_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 256 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d36c2a0d7a_7a4e4d2a_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d36c2a0d7a_7a4e4d2a_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: 491383919
);
-> 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: 491383919
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d36c2a0d7a_7a4e4d2a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824840876},
Mock for Store, hashCode: 491383919
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d36c2a0d7a_7a4e4d2a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824840876}
);
-> 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_d36c2a0d7a_7a4e4d2a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_e0021761eb_72dfa406_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_e0021761eb_72dfa406_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: 2028630624
);
-> 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: 2028630624
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_e0021761eb_72dfa406_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824894945},
Mock for Store, hashCode: 2028630624
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_e0021761eb_72dfa406_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824894945}
);
-> 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_e0021761eb_72dfa406_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
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)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 256 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d6c1df055f_aa92deb9_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_d6c1df055f_aa92deb9_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: 817424627
);
-> 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: 817424627
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d6c1df055f_aa92deb9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824855185},
Mock for Store, hashCode: 817424627
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_d6c1df055f_aa92deb9_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824855185}
);
-> 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_d6c1df055f_aa92deb9_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 236 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_947249790d_43a25f4e_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_947249790d_43a25f4e_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: 1808874211
);
-> 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: 1808874211
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_947249790d_43a25f4e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824974698},
Mock for Store, hashCode: 1808874211
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_947249790d_43a25f4e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824974698}
);
-> 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_947249790d_43a25f4e_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
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 236 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_947249790d_43a25f4e_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_947249790d_43a25f4e_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: 1808874211
);
-> 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: 1808874211
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_947249790d_43a25f4e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824974698},
Mock for Store, hashCode: 1808874211
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_947249790d_43a25f4e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769824974698}
);
-> 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_947249790d_43a25f4e_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
Router / UT & CodeCov (17)
Process completed with exit code 1.
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
Controller / UT & CodeCov (17)
Process completed with exit code 1.
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (79.3216) which is too far from the predictedUsage (40); delta: 0.983; maxAllowedDelta: 0.013. No more attempts left.
|
|
VeniceOpenTelemetryPerfTest.testTehutiVsOtelMetricRecordingPerf:
internal/venice-client-common/src/test/java/com/linkedin/venice/stats/VeniceOpenTelemetryPerfTest.java#L302
java.lang.AssertionError: OpenTelemetry should not be significantly slower than Tehuti expected [true] but found [false]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (79.3216) which is too far from the predictedUsage (40); delta: 0.983; maxAllowedDelta: 0.013. No more attempts left.
|
|
VeniceOpenTelemetryPerfTest.testTehutiVsOtelMetricRecordingPerf:
internal/venice-client-common/src/test/java/com/linkedin/venice/stats/VeniceOpenTelemetryPerfTest.java#L302
java.lang.AssertionError: OpenTelemetry should not be significantly slower than Tehuti expected [true] but found [false]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfoWithoutFabric:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L772
java.lang.AssertionError: expected [false] but found [true]
|
|
StoresRoutesTest.testGetRepushInfo:
services/venice-controller/src/test/java/com/linkedin/venice/controller/server/StoresRoutesTest.java#L726
java.lang.AssertionError: expected [false] but found [true]
|
|
Controller / UT & CodeCov (8)
Process completed with exit code 1.
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
However, there were exactly 27 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
6.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.05785d
);
-> 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.052758d
);
-> 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.08032900000000001d,
1769825813981L
);
-> 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.048753d
);
-> 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.606602d,
1769825813984L
);
-> 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.047424d
);
-> 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.035652d,
1769825813996L
);
-> 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
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
However, there were exactly 27 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
6.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.05785d
);
-> 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.052758d
);
-> 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.08032900000000001d,
1769825813981L
);
-> 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.048753d
);
-> 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.606602d,
1769825813984L
);
-> 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.047424d
);
-> 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.035652d,
1769825813996L
);
-> 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
|
|
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
Expired
|
829 KB |
sha256:65269a050beb6926f54136899311a7ab8932ca750f39bc0499e601eeb87c20e8
|
|
|
clients-jdk11
Expired
|
3.17 MB |
sha256:7dcdfc2b0b9986b8934ae11b704ecfa618ce4ca1c491151be21991b94a350a12
|
|
|
clients-jdk17
Expired
|
3.21 MB |
sha256:d737f68a51a459960b73b899ddc03230153a18a06fc05e5a393365a35709b976
|
|
|
clients-jdk8
Expired
|
3.17 MB |
sha256:95ad93613eb352485bb460e1ba0eb506b9a114cab2dc6083733bec4c638c4318
|
|
|
controller-jdk11
Expired
|
633 KB |
sha256:6c02d927f58605655825ce1c85e8159f36696bec918e4aa48b438f8980ee67c2
|
|
|
controller-jdk17
Expired
|
614 KB |
sha256:f5040fb7cc3acd3d6422170237b3c86d1190a50615cc0e113f062745a913c458
|
|
|
controller-jdk8
Expired
|
630 KB |
sha256:8533aa7d77b1bd686ff932d09feff3fe9413bf7ff8f6f53f35b68688e5bdfb62
|
|
|
integrations-jdk11
Expired
|
550 KB |
sha256:028c7396b9f95ea63c435d762a063939255798363d40d0fa1f64115f9e666aaa
|
|
|
integrations-jdk17
Expired
|
559 KB |
sha256:b55590d94e3a47ccefaf87c4b5bcb37ad7e820324e529a25059448d8e0539dd8
|
|
|
integrations-jdk8
Expired
|
539 KB |
sha256:3b04b78507b94fb6d59bb4e3aeb215abb6ac73c16cd688432a04eb84e96d2b17
|
|
|
internal-jdk11
Expired
|
4.31 MB |
sha256:9b0a3a9713399642609876ea28bdf0d51d485f60ba1e3dad3a313175413b5e02
|
|
|
internal-jdk17
Expired
|
4.32 MB |
sha256:2faac99c102d620ee502249082c93e48a23befeb60f23400077050354ea5bda1
|
|
|
internal-jdk8
Expired
|
4.3 MB |
sha256:1f75fccfd207d8ce5fb73707096bfe9b5be16aced83e335ab8dc75ae9ae1d324
|
|
|
router-jdk11
Expired
|
766 KB |
sha256:d3f160dbfc431857359c06263800c8710ca91bf4863b8ed404e657d04bd517c3
|
|
|
router-jdk17
Expired
|
774 KB |
sha256:3b86f4699597c07b9481df8152e0ec9c62be392002565ed10d03229357bfe19e
|
|
|
router-jdk8
Expired
|
755 KB |
sha256:9d63ecca2d3abd24fd7a65c4f703555182e0717d9c9622a668180ab26032a39e
|
|
|
server-jdk11
Expired
|
10.3 MB |
sha256:d5cd058dae766ef0c6a84613c1b9eed6890f0f498f62c5b5db4019f1420355c8
|
|
|
server-jdk17
Expired
|
10.4 MB |
sha256:bb4c05507c13283fd383afb0adb7a31cdc005f2b230795b137a82bc406dc73dd
|
|
|
server-jdk8
Expired
|
10.3 MB |
sha256:f0fc70243dbecdcb29efd42be64f4d6a26f6495bc7994a75557c55f948d1424c
|
|