Increase heap size to 8G for CI reporting (#1350) #751
GitHub Actions / JUnit Test Report
failed
Nov 27, 2024 in 0s
6786 tests run, 6782 passed, 0 skipped, 4 failed.
Annotations
github-actions / JUnit Test Report
SITWithTWiseAndBufferAfterLeaderTest.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 46 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_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.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_v1-1,
-1L,
"local_InMemoryKafkaBroker:37285"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:37285"},
"local_InMemoryKafkaBroker:37285",
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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> 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 46 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_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.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_v1-1,
-1L,
"local_InMemoryKafkaBroker:37285"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:37285"},
"local_InMemoryKafkaBroker:37285",
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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5119)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testProcessConsumerActionsError(StoreIngestionTaskTest.java:5105)
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 [email protected]/sun.util.calendar.CalendarDate.<init>(CalendarDate.java:93)
at [email protected]/sun.util.calendar.BaseCalendar$Date.<init>(BaseCalendar.java:148)
at [email protected]/sun.util.calendar.Gregorian$Date.<init>(Gregorian.java:45)
at [email protected]/sun.util.calendar.Gregorian.newCalendarDate(Gregorian.java:85)
at [email protected]/java.util.GregorianCalendar.<init>(GregorianCalendar.java:739)
at [email protected]/java.util.Calendar$Builder.build(Calendar.java:1492)
at [email protected]/sun.util.locale.provider.CalendarProviderImpl.getInstance(CalendarProviderImpl.java:87)
at [email protected]/java.util.Calendar.createCalendar(Calendar.java:1692)
at [email protected]/java.util.Calendar.getInstance(Calendar.java:1671)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.newCalendar(FastDatePrinter.java:467)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.format(FastDatePrinter.java:448)
at app//org.apache.logging.log4j.core.util.datetime.FastDateFormat.format(FastDateFormat.java:431)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$PatternFormatter.format(DatePatternConverter.java:68)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java:155)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:310)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:290)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:265)
at app//org.apache.logging.log4j.core.layout.PatternLayout$NoFormatPatternSerializer.toSerializable(PatternLayout.java:343)
at app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:241)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:226)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:60)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:197)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:190)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:181)
at app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:161)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:134)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:125)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:89)
at app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:542)
at app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:500)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:483)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:417)
at app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:82)
at app//org.apache.logging.log4j.core.Logger.log(Logger.java:161)
at app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2205)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2159)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2142)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2046)
at app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1915)
at app//org.apache.logging.log4j.spi.AbstractLogger.info(AbstractLogger.java:1454)
at app//com.linkedin.venice.fastclient.utils.TestClientSimulator.restRequest(TestClientSimulator.java:266)
at app//com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:51)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
at app//com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
at app//com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
at app//com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
github-actions / JUnit Test Report
SITWithTWiseAndBufferAfterLeaderTest.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 46 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_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.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_v1-1,
-1L,
"local_InMemoryKafkaBroker:37285"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:37285"},
"local_InMemoryKafkaBroker:37285",
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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> 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 46 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:872)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5e5e41d305_4067eaaf_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.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1595)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_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_5e5e41d305_4067eaaf_v1-1,
-1L,
"local_InMemoryKafkaBroker:37285"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2119)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:37285"},
"local_InMemoryKafkaBroker:37285",
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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:565)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636},
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1864)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5e5e41d305_4067eaaf_v1-1, attempts=4, sequenceNumber=1, createdTimestampInMs=1732671329636}
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> 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: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1473240040
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5113)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4148)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$156(StoreIngestionTaskTest.java:5119)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:879)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:773)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:633)
at app//com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.testProcessConsumerActionsError(StoreIngestionTaskTest.java:5105)
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 [email protected]/sun.util.calendar.CalendarDate.<init>(CalendarDate.java:93)
at [email protected]/sun.util.calendar.BaseCalendar$Date.<init>(BaseCalendar.java:148)
at [email protected]/sun.util.calendar.Gregorian$Date.<init>(Gregorian.java:45)
at [email protected]/sun.util.calendar.Gregorian.newCalendarDate(Gregorian.java:85)
at [email protected]/java.util.GregorianCalendar.<init>(GregorianCalendar.java:739)
at [email protected]/java.util.Calendar$Builder.build(Calendar.java:1492)
at [email protected]/sun.util.locale.provider.CalendarProviderImpl.getInstance(CalendarProviderImpl.java:87)
at [email protected]/java.util.Calendar.createCalendar(Calendar.java:1692)
at [email protected]/java.util.Calendar.getInstance(Calendar.java:1671)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.newCalendar(FastDatePrinter.java:467)
at app//org.apache.logging.log4j.core.util.datetime.FastDatePrinter.format(FastDatePrinter.java:448)
at app//org.apache.logging.log4j.core.util.datetime.FastDateFormat.format(FastDateFormat.java:431)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$PatternFormatter.format(DatePatternConverter.java:68)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java:155)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:310)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:290)
at app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:265)
at app//org.apache.logging.log4j.core.layout.PatternLayout$NoFormatPatternSerializer.toSerializable(PatternLayout.java:343)
at app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:241)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:226)
at app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:60)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:197)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:190)
at app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:181)
at app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:161)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:134)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:125)
at app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:89)
at app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:542)
at app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:500)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:483)
at app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:417)
at app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:82)
at app//org.apache.logging.log4j.core.Logger.log(Logger.java:161)
at app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2205)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2159)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2142)
at app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2046)
at app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:1915)
at app//org.apache.logging.log4j.spi.AbstractLogger.info(AbstractLogger.java:1454)
at app//com.linkedin.venice.fastclient.utils.TestClientSimulator.restRequest(TestClientSimulator.java:266)
at app//com.linkedin.venice.fastclient.transport.R2TransportClient.post(R2TransportClient.java:51)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.multiKeyStreamingRequest(DispatchingAvroGenericStoreClient.java:479)
at app//com.linkedin.venice.fastclient.DispatchingAvroGenericStoreClient.streamingBatchGet(DispatchingAvroGenericStoreClient.java:365)
at app//com.linkedin.venice.fastclient.DelegatingAvroStoreClient.streamingBatchGet(DelegatingAvroStoreClient.java:99)
at app//com.linkedin.venice.fastclient.StatsAvroGenericStoreClient.streamingBatchGet(StatsAvroGenericStoreClient.java:70)
at app//com.linkedin.venice.fastclient.InternalAvroStoreClient.streamingBatchGet(InternalAvroStoreClient.java:65)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:770)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.callStreamingBatchGetAndVerifyResults(BatchGetAvroStoreClientUnitTest.java:759)
at app//com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet(BatchGetAvroStoreClientUnitTest.java:65)
Loading