[server] Switch back to PubSubPosition based reads with offset as fallback #9560
Annotations
10 errors
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
Wanted 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
But was 0 times.
|
|
Publish Test Report:
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 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6c69a70bcf_9fe7c671_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6c69a70bcf_9fe7c671_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:754)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:801)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:711)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4533)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:807)
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:4533)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 961436282
);
-> 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:5251)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5252)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 961436282
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6c69a70bcf_9fe7c671_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740068205},
Mock for Store, hashCode: 961436282
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6c69a70bcf_9fe7c671_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740068205}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
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:5068)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_6c69a70bcf_9fe7c671_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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:2781)
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
topicManager.getLatestPositionCachedNonBlocking(
<any com.linkedin.venice.pubsub.api.PubSubTopicPartition>
);
Wanted *at least* 10 times:
-> at com.linkedin.venice.pubsub.manager.TopicManager.getLatestPositionCachedNonBlocking(TopicManager.java:895)
But was 9 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
|
|
Publish Test Report:
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 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6b7616f692_9bd9aaef_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6b7616f692_9bd9aaef_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:754)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:801)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:711)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4533)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:807)
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:4533)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1258232867
);
-> 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:5251)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5252)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1258232867
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6b7616f692_9bd9aaef_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740064135},
Mock for Store, hashCode: 1258232867
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6b7616f692_9bd9aaef_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740064135}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
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:5068)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_6b7616f692_9bd9aaef_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
Wanted 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
But was 0 times.
|
|
Publish Test Report:
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 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6c69a70bcf_9fe7c671_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6c69a70bcf_9fe7c671_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:754)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:801)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:711)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4533)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:807)
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:4533)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 961436282
);
-> 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:5251)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5252)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 961436282
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6c69a70bcf_9fe7c671_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740068205},
Mock for Store, hashCode: 961436282
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6c69a70bcf_9fe7c671_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740068205}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
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:5068)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_6c69a70bcf_9fe7c671_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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:2781)
|
|
Publish Test Report:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
topicManager.getLatestPositionCachedNonBlocking(
<any com.linkedin.venice.pubsub.api.PubSubTopicPartition>
);
Wanted *at least* 10 times:
-> at com.linkedin.venice.pubsub.manager.TopicManager.getLatestPositionCachedNonBlocking(TopicManager.java:895)
But was 9 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.lambda$getTopicPartitionEndPosition$15(StoreIngestionTask.java:2533)
|
|
Publish Test Report:
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 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6b7616f692_9bd9aaef_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:990)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6b7616f692_9bd9aaef_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:754)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:801)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:711)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4533)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:807)
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:4533)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1258232867
);
-> 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:5251)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5252)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1258232867
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6b7616f692_9bd9aaef_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740064135},
Mock for Store, hashCode: 1258232867
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6b7616f692_9bd9aaef_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1767740064135}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:597)
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:5068)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_6b7616f692_9bd9aaef_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
Loading