[server] Otel integration in server for HeartBeatStat Metrics #9555
Annotations
6 errors
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2766)
|
|
Publish Test Report:
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:1601)
However, there were exactly 255 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_3d429fc355_b5a5c53a_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_3d429fc355_b5a5c53a_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:743)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:790)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:700)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:796)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1767)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1506874164
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1770)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1771)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5266)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5267)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1506874164
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1772)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3d429fc355_b5a5c53a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736775167},
Mock for Store, hashCode: 1506874164
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2111)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3d429fc355_b5a5c53a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736775167}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2301)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5040)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_3d429fc355_b5a5c53a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
Publish Test Report:
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:1601)
However, there were exactly 295 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4b606cf59e_98f5a132_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4b606cf59e_98f5a132_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:743)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:790)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:700)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:796)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1767)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 935600478
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1770)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1771)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5266)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5267)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 935600478
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1772)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b606cf59e_98f5a132_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736835818},
Mock for Store, hashCode: 935600478
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2111)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b606cf59e_98f5a132_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736835818}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2301)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5040)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_4b606cf59e_98f5a132_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2766)
|
|
Publish Test Report:
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:1601)
However, there were exactly 255 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_3d429fc355_b5a5c53a_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_3d429fc355_b5a5c53a_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:743)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:790)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:700)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:796)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1767)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1506874164
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1770)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1771)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5266)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5267)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1506874164
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1772)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3d429fc355_b5a5c53a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736775167},
Mock for Store, hashCode: 1506874164
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2111)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3d429fc355_b5a5c53a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736775167}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2301)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5040)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_3d429fc355_b5a5c53a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
Publish Test Report:
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:1601)
However, there were exactly 295 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4b606cf59e_98f5a132_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4b606cf59e_98f5a132_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:743)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:790)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:700)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:796)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1767)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4512)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 935600478
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1770)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1771)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5266)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5267)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 935600478
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1772)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b606cf59e_98f5a132_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736835818},
Mock for Store, hashCode: 935600478
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2111)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4b606cf59e_98f5a132_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767736835818}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2301)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5040)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_4b606cf59e_98f5a132_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
Loading