add protection to eager swap before consumer is fully subscribed #201
GitHub Actions / JUnit Test Report
failed
Dec 5, 2024 in 0s
6800 tests run, 6784 passed, 0 skipped, 16 failed.
Annotations
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
SITWithPWiseAndBufferAfterLeaderTest.testProcessConsumerActionsError
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
However, there were exactly 53 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:593)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:607)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:554)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:616)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2108)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2113)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
-1L,
"local_InMemoryKafkaBroker:40563"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:40563"},
"local_InMemoryKafkaBroker:40563",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3498)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)Raw output
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
However, there were exactly 53 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:593)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:607)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:554)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:616)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2108)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2113)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
-1L,
"local_InMemoryKafkaBroker:40563"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:40563"},
"local_InMemoryKafkaBroker:40563",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3498)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5119)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testProcessConsumerActionsError(StoreIngestionTaskTest.java:5105)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
SITWithTWiseWithoutBufferAfterLeaderTest.testOffsetSyncBeforeGracefulShutDown[1](AA_OFF)
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
Raw output
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:547)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testOffsetSyncBeforeGracefulShutDown$113(StoreIngestionTaskTest.java:4132)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testOffsetSyncBeforeGracefulShutDown(StoreIngestionTaskTest.java:4166)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
Raw output
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
at java.io.UnixFileSystem.canonicalize0(Native Method)
at java.io.UnixFileSystem.canonicalize(UnixFileSystem.java:177)
at java.io.File.getCanonicalPath(File.java:626)
at java.io.FilePermission$1.run(FilePermission.java:248)
at java.io.FilePermission$1.run(FilePermission.java:236)
at java.security.AccessController.doPrivileged(Native Method)
at java.io.FilePermission.init(FilePermission.java:236)
at java.io.FilePermission.<init>(FilePermission.java:310)
at java.lang.SecurityManager.checkRead(SecurityManager.java:888)
at java.io.File.exists(File.java:825)
at sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:1391)
at sun.misc.URLClassPath.getResource(URLClassPath.java:250)
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:363)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:362)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
at com.linkedin.r2.message.BaseMessageBuilder.setHeaders(BaseMessageBuilder.java:76)
at com.linkedin.r2.message.BaseMessageBuilder.<init>(BaseMessageBuilder.java:57)
at com.linkedin.r2.message.BaseRequestBuilder.<init>(BaseRequestBuilder.java:47)
at com.linkedin.r2.message.rest.RestRequestBuilder.<init>(RestRequestBuilder.java:35)
at com.linkedin.venice.D2.D2ClientUtils.createD2PostRequest(D2ClientUtils.java:137)
at com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:49)
at com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
at com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
at com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
at com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
at com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
at com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
at com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
at com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)Raw output
Wanted but not invoked:
veniceAfterImageConsumerImpl.seekToEndOfPush(
<any set>
);
-> at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
However, there was exactly 1 interaction with this mock:
veniceAfterImageConsumerImpl.subscribed();
-> at com.linkedin.davinci.consumer.VersionSwapDataChangeListener.handleStoreChanged(VersionSwapDataChangeListener.java:35)
at com.linkedin.davinci.consumer.VeniceAfterImageConsumerImpl.seekToEndOfPush(VeniceAfterImageConsumerImpl.java:109)
at com.linkedin.davinci.consumer.VeniceChangelogConsumerImplTest.testVersionSwapDataChangeListener(VeniceChangelogConsumerImplTest.java:442)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
SITWithPWiseAndBufferAfterLeaderTest.testProcessConsumerActionsError
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
However, there were exactly 53 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:593)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:607)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:554)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:616)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2108)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2113)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
-1L,
"local_InMemoryKafkaBroker:40563"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:40563"},
"local_InMemoryKafkaBroker:40563",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3498)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)Raw output
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
However, there were exactly 53 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:593)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:607)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:554)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:616)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2108)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_6fb251cc4a_25d14cb6_v1-1, hybrid=false, latestProcessedLocalVersionTopicOffset=-1, latestProcessedUpstreamVersionTopicOffset=-1, latestProcessedUpstreamRTOffsetMap={}, latestIgnoredUpstreamRTOffsetMap={}, latestRTOffsetTriedToProduceToVTMap{}, offsetRecord=OffsetRecord{localVersionTopicOffset=-1, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}, errorReported=false, started=false, lagCaughtUp=false, processedRecordSizeSinceLastSync=0, leaderFollowerState=STANDBY}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2113)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_6fb251cc4a_25d14cb6_v1-1,
-1L,
"local_InMemoryKafkaBroker:40563"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:40563"},
"local_InMemoryKafkaBroker:40563",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3498)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.StorePartitionDataReceiver.destinationIdentifier(StorePartitionDataReceiver.java:86)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906},
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_6fb251cc4a_25d14cb6_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733430971906}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1598)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3749)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1592)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:3990)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1594)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1511)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1596)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:764)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1597)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1464)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 207494990
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5119)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testProcessConsumerActionsError(StoreIngestionTaskTest.java:5105)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
SITWithTWiseWithoutBufferAfterLeaderTest.testOffsetSyncBeforeGracefulShutDown[1](AA_OFF)
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
Raw output
java.lang.AssertionError: pcs.getLatestProcessedLocalVersionTopicOffset() for PARTITION_FOO is expected to be zero! expected [0] but found [2]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:547)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testOffsetSyncBeforeGracefulShutDown$113(StoreIngestionTaskTest.java:4132)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testOffsetSyncBeforeGracefulShutDown(StoreIngestionTaskTest.java:4166)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:583)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:719)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:989)
at org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)
at org.testng.TestRunner.privateRun(TestRunner.java:648)
at org.testng.TestRunner.run(TestRunner.java:505)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:455)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)
at org.testng.SuiteRunner.run(SuiteRunner.java:364)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1208)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1137)
at org.testng.TestNG.runSuites(TestNG.java:1049)
at org.testng.TestNG.run(TestNG.java:1017)
github-actions / JUnit Test Report
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
Raw output
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
at java.io.UnixFileSystem.canonicalize0(Native Method)
at java.io.UnixFileSystem.canonicalize(UnixFileSystem.java:177)
at java.io.File.getCanonicalPath(File.java:626)
at java.io.FilePermission$1.run(FilePermission.java:248)
at java.io.FilePermission$1.run(FilePermission.java:236)
at java.security.AccessController.doPrivileged(Native Method)
at java.io.FilePermission.init(FilePermission.java:236)
at java.io.FilePermission.<init>(FilePermission.java:310)
at java.lang.SecurityManager.checkRead(SecurityManager.java:888)
at java.io.File.exists(File.java:825)
at sun.misc.URLClassPath$FileLoader.getResource(URLClassPath.java:1391)
at sun.misc.URLClassPath.getResource(URLClassPath.java:250)
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:363)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:362)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
at com.linkedin.r2.message.BaseMessageBuilder.setHeaders(BaseMessageBuilder.java:76)
at com.linkedin.r2.message.BaseMessageBuilder.<init>(BaseMessageBuilder.java:57)
at com.linkedin.r2.message.BaseRequestBuilder.<init>(BaseRequestBuilder.java:47)
at com.linkedin.r2.message.rest.RestRequestBuilder.<init>(RestRequestBuilder.java:35)
at com.linkedin.venice.D2.D2ClientUtils.createD2PostRequest(D2ClientUtils.java:137)
at com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:49)
at com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
at com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
at com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
at com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
at com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
at com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
at com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
at com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Loading