[test] Fix TestChangelogConsumer and address related issues (#1384) #77
ZacAttackAnnotations
53 errors and 1 warning
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
com.linkedin.venice.helixrebalance.TestRebalanceByDefaultStrategy ► testRollingUpgrade:
internal/venice-test-common/src/main/java/com/linkedin/venice/utils/TestUtils.java#L171
Failed test found in:
IntegrationTests_1060-artifacts/internal/venice-test-common/build/test-results/integrationTests_1060/TEST-com.linkedin.venice.helixrebalance.TestRebalanceByDefaultStrategy.xml
internal/venice-test-common/build/test-results/integrationTests_1060/TEST-com.linkedin.venice.helixrebalance.TestRebalanceByDefaultStrategy.xml
Error:
java.lang.AssertionError: Non-deterministic condition not met. expected [true] but found [false]
|
|
SITWithPWiseAndBufferAfterLeaderTest.testCorruptMessagesFailFast[134](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_772c981a28_931592e6_v1",
1,
LongEqualOrGreaterThanMatcher(lowerBound=3),
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:26)
However, there were exactly 3 interactions with this mock:
logNotifier.started(
"TestTopic_772c981a28_931592e6_v1",
2
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.started(
"TestTopic_772c981a28_931592e6_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_772c981a28_931592e6_v1",
1,
3L
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:205)
|
|
SITWithTWiseAndBufferAfterLeaderTest.testProcessConsumerActionsError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4213)
However, there were exactly 45 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_790849918b_4b2bb784_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:878)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_790849918b_4b2bb784_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:612)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:626)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:573)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:635)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687},
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_790849918b_4b2bb784_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:2129)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_790849918b_4b2bb784_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:2134)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_790849918b_4b2bb784_v1,
PCS{replicaId=TestTopic_790849918b_4b2bb784_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},
-1L,
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2138)
leaderFollowerStoreIngestionTask.resolveTopicPartitionWithKafkaURL(
TestTopic_790849918b_4b2bb784_v1,
PCS{replicaId=TestTopic_790849918b_4b2bb784_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},
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3536)
leaderFollowerStoreIngestionTask.resolveTopicWithKafkaURL(
TestTopic_790849918b_4b2bb784_v1,
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resolveTopicPartitionWithKafkaURL(StoreIngestionTask.java:4526)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_790849918b_4b2bb784_v1-1,
-1L,
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3537)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:42827"},
"local_InMemoryKafkaBroker:42827",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3549)
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: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687},
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1617)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3755)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L65
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
SITWithPWiseAndBufferAfterLeaderTest.testCorruptMessagesFailFast[134](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_772c981a28_931592e6_v1",
1,
LongEqualOrGreaterThanMatcher(lowerBound=3),
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:26)
However, there were exactly 3 interactions with this mock:
logNotifier.started(
"TestTopic_772c981a28_931592e6_v1",
2
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.started(
"TestTopic_772c981a28_931592e6_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:107)
logNotifier.progress(
"TestTopic_772c981a28_931592e6_v1",
1,
3L
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:205)
|
|
SITWithTWiseAndBufferAfterLeaderTest.testProcessConsumerActionsError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4213)
However, there were exactly 45 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_790849918b_4b2bb784_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:878)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_790849918b_4b2bb784_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:612)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:626)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:573)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:635)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687},
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_790849918b_4b2bb784_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:2129)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_790849918b_4b2bb784_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:2134)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_790849918b_4b2bb784_v1,
PCS{replicaId=TestTopic_790849918b_4b2bb784_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},
-1L,
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2138)
leaderFollowerStoreIngestionTask.resolveTopicPartitionWithKafkaURL(
TestTopic_790849918b_4b2bb784_v1,
PCS{replicaId=TestTopic_790849918b_4b2bb784_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},
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3536)
leaderFollowerStoreIngestionTask.resolveTopicWithKafkaURL(
TestTopic_790849918b_4b2bb784_v1,
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resolveTopicPartitionWithKafkaURL(StoreIngestionTask.java:4526)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_790849918b_4b2bb784_v1-1,
-1L,
"local_InMemoryKafkaBroker:42827"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3537)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:42827"},
"local_InMemoryKafkaBroker:42827",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3549)
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: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687},
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_790849918b_4b2bb784_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1733943302687}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1617)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3755)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1936100606
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L65
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
TestRemoteIngestionRepairService.testIngestionRepairService:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/TestRemoteIngestionRepairService.java#L25
java.lang.AssertionError: expected [2] but found [1]
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L146
java.lang.AssertionError: expected [NaN] but found [0.0]
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L1
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
TestRemoteIngestionRepairService.testIngestionRepairService:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/TestRemoteIngestionRepairService.java#L25
java.lang.AssertionError: expected [2] but found [1]
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L146
java.lang.AssertionError: expected [NaN] but found [0.0]
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L1
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
com.linkedin.venice.endToEnd.MetaSystemStoreTest ► testThinClientMetaStoreBasedRepositoryWithLargeValueSchemas:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/MetaSystemStoreTest.java#L315
Failed test found in:
IntegrationTests_1500-artifacts/internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml
internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml
Error:
java.lang.AssertionError: Number of value schemas should be the same between meta system store and controller expected [2] but found [1]
|
|
com.linkedin.venice.consumer.TestChangelogConsumer ► testAAIngestionWithStoreView:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/consumer/TestChangelogConsumer.java#L638
Failed test found in:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml
Error:
java.lang.AssertionError: expected [85] but found [91]
|
|
com.linkedin.venice.consumer.TestChangelogConsumer ► testAAIngestionWithStoreView:
internal/venice-common/src/main/java/com/linkedin/venice/controllerapi/ControllerClient.java#L490
Failed test found in:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml
Error:
com.linkedin.venice.exceptions.VeniceException: sendEmptyPushAndWait did not succeed in the allotted time (30000 ms). Last status: JobStatusQueryResponse(
|
|
com.linkedin.venice.consumer.TestChangelogConsumer ► testAAIngestionWithStoreView:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml#L0
Failed test found in:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml
Error:
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.consumer.TestChangelogConsumer.testAAIngestionWithStoreView() didn't finish within the time-out 360000
|
|
com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing ► testAAIngestionWithStoreView:
internal/venice-common/src/main/java/com/linkedin/venice/controllerapi/ControllerClient.java#L490
Failed test found in:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
Error:
com.linkedin.venice.exceptions.VeniceException: sendEmptyPushAndWait did not succeed in the allotted time (30000 ms). Last status: JobStatusQueryResponse(
|
|
com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing ► testAAIngestionWithStoreView:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml#L0
Failed test found in:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
Error:
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.consumer.TestChangelogConsumer.testAAIngestionWithStoreView() didn't finish within the time-out 360000
|
|
com.linkedin.venice.consumer.TestChangelogConsumer ► testAAIngestionWithStoreView:
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml#L0
Failed test found in:
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumer.xml
Error:
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.consumer.TestChangelogConsumer.testAAIngestionWithStoreView() didn't finish within the time-out 360000
|
|
com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing ► testAAIngestionWithStoreView:
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml#L0
Failed test found in:
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
Error:
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.consumer.TestChangelogConsumer.testAAIngestionWithStoreView() didn't finish within the time-out 360000
|
|
com.linkedin.venice.endToEnd.TestPartialUpdateWithActiveActiveReplication ► testAAReplicationForPartialUpdateOnFields:
services/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceHelixAdmin.java#L3196
Failed test found in:
IntegrationTests_9999-artifacts/internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestPartialUpdateWithActiveActiveReplication.xml
internal/venice-test-common/build/test-results/integrationTests_9999/TEST-com.linkedin.venice.endToEnd.TestPartialUpdateWithActiveActiveReplication.xml
Error:
java.lang.AssertionError: Controller error: An error occurred during controller request. controller = http://localhost:39697, route = /new_store, params = [owner=owner, key_schema={"type" : "string"}, cluster_name=venice-cluster0, hostname=localhost, store_name=test-store-aa-wc_e054657b00_e97f0dc1, value_schema={"type":"record","name":"Person","namespace":"example.avro","fields":[{"name":"name","type":"string","default":"default_name"},{"name":"age","type":"int","default":-1}]}], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 500 - Failed to add version: -1 to store: venice_system_store_meta_store_test-store-aa-wc_e054657b00_e97f0dc1 in cluster: venice-cluster0. Detailed stack trace: com.linkedin.venice.exceptions.VeniceException: Store: venice_system_store_meta_store_test-store-aa-wc_e054657b00_e97f0dc1 is not initialized with a version yet
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
TestVeniceDelegateMode.testScatterForMultiGetWithHelixAssistedRouting:
services/venice-router/src/test/java/com/linkedin/venice/router/api/TestVeniceDelegateMode.java#L726
java.lang.AssertionError: expected [true] but found [false]
|
|
com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing ► testSpecificRecordVeniceChangelogConsumer:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/consumer/TestChangelogConsumer.java#L857
Failed test found in:
IntegrationTests_1030-artifacts/internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
internal/venice-test-common/build/test-results/integrationTests_1030/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
Error:
java.lang.AssertionError: expected [2] but found [1]
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L133
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L1
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L133
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L1
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L1
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L1
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
SITWithTWiseAndBufferAfterLeaderTest.testProcessConsumerActionsError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4213)
However, there were exactly 45 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_87c32c67e1_ba89f868_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:878)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_87c32c67e1_ba89f868_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:612)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:626)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:573)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:635)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701},
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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:2129)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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:2134)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_87c32c67e1_ba89f868_v1,
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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},
-1L,
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2138)
leaderFollowerStoreIngestionTask.resolveTopicPartitionWithKafkaURL(
TestTopic_87c32c67e1_ba89f868_v1,
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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},
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3536)
leaderFollowerStoreIngestionTask.resolveTopicWithKafkaURL(
TestTopic_87c32c67e1_ba89f868_v1,
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resolveTopicPartitionWithKafkaURL(StoreIngestionTask.java:4526)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_87c32c67e1_ba89f868_v1-1,
-1L,
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3537)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:38645"},
"local_InMemoryKafkaBroker:38645",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3549)
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: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701},
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1617)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3755)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
|
|
SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1612)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@54ea158
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@1561d534
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598434, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598435, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@7717ce60
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598434, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598435, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@39854660
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598435, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
|
|
SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
1,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1612)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
"TestTopic_a999d7d7f9_1439537f_v1",
1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
"TestTopic_a999d7d7f9_1439537f_v1",
2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@1bb68d96
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@24c6d0ec
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
2,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
1,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732034, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
2,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@522cdfe9
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
2,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
1,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@5446be0f
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L65
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
SITWithTWiseAndBufferAfterLeaderTest.testProcessConsumerActionsError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportError(
<any string>,
1,
<Capturing argument>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportError(StoreIngestionTask.java:4213)
However, there were exactly 45 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_87c32c67e1_ba89f868_v1-1
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:878)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_87c32c67e1_ba89f868_v1-1,
true
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:612)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:626)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:573)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:635)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701},
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.reportIfCatchUpVersionTopicOffset(
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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:2129)
leaderFollowerStoreIngestionTask.updateLeaderTopicOnFollower(
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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:2134)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_87c32c67e1_ba89f868_v1,
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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},
-1L,
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2138)
leaderFollowerStoreIngestionTask.resolveTopicPartitionWithKafkaURL(
TestTopic_87c32c67e1_ba89f868_v1,
PCS{replicaId=TestTopic_87c32c67e1_ba89f868_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},
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3536)
leaderFollowerStoreIngestionTask.resolveTopicWithKafkaURL(
TestTopic_87c32c67e1_ba89f868_v1,
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.resolveTopicPartitionWithKafkaURL(StoreIngestionTask.java:4526)
leaderFollowerStoreIngestionTask.consumerSubscribe(
TestTopic_87c32c67e1_ba89f868_v1-1,
-1L,
"local_InMemoryKafkaBroker:38645"
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3537)
leaderFollowerStoreIngestionTask.createKafkaConsumerProperties(
{"kafka.bootstrap.servers" = "local_InMemoryKafkaBroker:38645"},
"local_InMemoryKafkaBroker:38645",
false
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.consumerSubscribe(StoreIngestionTask.java:3549)
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: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701},
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:1885)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_87c32c67e1_ba89f868_v1-1, attempts=2, sequenceNumber=1, createdTimestampInMs=1734142586701}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:569)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
leaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1617)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.maybeSendIngestionHeartbeat(LeaderFollowerStoreIngestionTask.java:3755)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1611)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4046)
leaderFollowerStoreIngestionTask.updateIngestionRoleIfStoreChanged(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1613)
leaderFollowerStoreIngestionTask.isHybridMode();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.updateIngestionRoleIfStoreChanged(StoreIngestionTask.java:1530)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1614)
leaderFollowerStoreIngestionTask.checkLongRunningTaskState();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1615)
leaderFollowerStoreIngestionTask.getVersionTopic();
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:767)
leaderFollowerStoreIngestionTask.checkIngestionProgress(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1616)
leaderFollowerStoreIngestionTask.consumerHasAnySubscription();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.checkIngestionProgress(StoreIngestionTask.java:1483)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1147537579
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testProcessConsumerActionsError$153(StoreIngestionTaskTest.java:5158)
|
|
SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1612)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@54ea158
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@1561d534
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598434, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
1,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598435, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@7717ce60
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598434, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598435, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_8a7f0d8a22_2c184b68_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$715/1864699804@39854660
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_8a7f0d8a22_2c184b68_v1",
2,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142598435, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
|
|
SITWithTWiseWithoutBufferAfterLeaderTest.testNotifier[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithTWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
1,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=0, eventTimeEpochMs=-1, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testNotifier$35(StoreIngestionTaskTest.java:1612)
Actual invocations have different arguments:
storageMetadataService.getLastOffset(
"TestTopic_a999d7d7f9_1439537f_v1",
1
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.getLastOffset(
"TestTopic_a999d7d7f9_1439537f_v1",
2
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.getLastOffset(DeepCopyOffsetManager.java:49)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@1bb68d96
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@24c6d0ec
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
2,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
1,
OffsetRecord{localVersionTopicOffset=1, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732034, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
2,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@522cdfe9
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
2,
OffsetRecord{localVersionTopicOffset=3, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=true, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.put(
"TestTopic_a999d7d7f9_1439537f_v1",
1,
OffsetRecord{localVersionTopicOffset=2, upstreamOffset=-1, leaderTopic=null, offsetLag=9223372036854775807, eventTimeEpochMs=1734142732035, latestProducerProcessingTimeInMs=0, isEndOfPushReceived=false, databaseInfo={}, realTimeProducerState={}}
);
-> at com.linkedin.venice.offsets.DeepCopyOffsetManager.put(DeepCopyOffsetManager.java:38)
storageMetadataService.computeStoreVersionState(
"TestTopic_a999d7d7f9_1439537f_v1",
com.linkedin.venice.offsets.DeepCopyStorageMetadataService$$Lambda$256/1906403371@5446be0f
);
-> at com.linkedin.venice.offsets.DeepCopyStorageMetadataService.computeStoreVersionState(DeepCopyStorageMetadataService.java:33)
|
|
BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet:
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/BatchGetAvroStoreClientUnitTest.java#L65
org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.fastclient.BatchGetAvroStoreClientUnitTest.testSimpleStreamingBatchGet() didn't finish within the time-out 5000
|
|
com.linkedin.venice.endToEnd.TestPushJobWithNativeReplication ► testActiveActiveForHeartbeatSystemStores:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/utils/IntegrationTestPushUtils.java#L328
Failed test found in:
IntegrationTests_1220-artifacts/internal/venice-test-common/build/test-results/integrationTests_1220/TEST-com.linkedin.venice.endToEnd.TestPushJobWithNativeReplication.xml
internal/venice-test-common/build/test-results/integrationTests_1220/TEST-com.linkedin.venice.endToEnd.TestPushJobWithNativeReplication.xml
Error:
com.linkedin.venice.exceptions.VeniceException: Could not create store testActiveActiveForHeartbeatSystemStores_71eaed43b0_73df03f5
|
|
com.linkedin.venice.controller.server.TestAdminSparkServer ► controllerClientCanQueryReplicasForTopic:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/controller/server/TestAdminSparkServer.java#L168
Failed test found in:
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml
Error:
java.lang.AssertionError: An error occurred during controller request. controller = http://localhost:40703, route = /list_replicas, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_98b0af2ba7_3bbd9e06, version=1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 500 - Resource 'test-store_98b0af2ba7_3bbd9e06_v1' does not exist expected [false] but found [true]
|
|
com.linkedin.venice.endToEnd.MetaSystemStoreTest ► testThinClientMetaStoreBasedRepositoryWithLargeValueSchemas:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/MetaSystemStoreTest.java#L315
Failed test found in:
IntegrationTests_1500-artifacts/internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml
internal/venice-test-common/build/test-results/integrationTests_1500/TEST-com.linkedin.venice.endToEnd.MetaSystemStoreTest.xml
Error:
java.lang.AssertionError: Number of value schemas should be the same between meta system store and controller expected [2] but found [1]
|
|
com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest ► testBlobP2PTransferAmongServersForBatchStore:
internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/endToEnd/BlobP2PTransferAmongServersTest.java#L123
Failed test found in:
IntegrationTests_1130-artifacts/internal/venice-test-common/build/test-results/integrationTests_1130/TEST-com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest.xml
IntegrationTests_1130-artifacts/internal/venice-test-common/build/test-results/integrationTests_1130/TEST-com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest.xml
IntegrationTests_1130-artifacts/internal/venice-test-common/build/test-results/integrationTests_1130/TEST-com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest.xml
internal/venice-test-common/build/test-results/integrationTests_1130/TEST-com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest.xml
internal/venice-test-common/build/test-results/integrationTests_1130/TEST-com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest.xml
internal/venice-test-common/build/test-results/integrationTests_1130/TEST-com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest.xml
Error:
java.lang.AssertionError: expected [true] but found [false]
|
|
PublishJavaDoc
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|