fix(controller): align proto message names for getClusterHealthStores… #430
pthirun
Matrix: Clients / UT & CodeCov
Matrix: Controller / UT & CodeCov
Matrix: Integrations / UT & CodeCov
Matrix: Internal / UT & CodeCov
Matrix: Router / UT & CodeCov
Matrix: Server / UT & CodeCov
Matrix: StaticAnalysis
ValidateGradleWrapper
9s
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
26 errors and 2 warnings
|
LeakedPushStatusCleanUpServiceTest.testLeakedZKNodeShouldBeDeleted:
services/venice-controller/src/test/java/com/linkedin/venice/pushmonitor/LeakedPushStatusCleanUpServiceTest.java#L95
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpServiceTest.testLeakedZKNodeShouldBeDeleted(LeakedPushStatusCleanUpServiceTest.java:95)
Actual invocations have different arguments:
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushSta
|
|
LeakedPushStatusCleanUpServiceTest.testLeakedZKNodeShouldBeDeleted:
services/venice-controller/src/test/java/com/linkedin/venice/pushmonitor/LeakedPushStatusCleanUpServiceTest.java#L95
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpServiceTest.testLeakedZKNodeShouldBeDeleted(LeakedPushStatusCleanUpServiceTest.java:95)
Actual invocations have different arguments:
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:129)
offlinePushAccessor.getOfflinePushStatusCreationTime(
"test_store_v2"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.run(LeakedPushStatusCleanUpService.java:152)
offlinePushAccessor.deleteOfflinePushStatusAndItsPartitionStatuses(
"test_store_v1"
);
-> at com.linkedin.venice.pushmonitor.LeakedPushStatusCleanUpService$PushStatusCleanUpTask.lambda$run$1(LeakedPushStatusCleanUpService.java:183)
offlinePushAccessor.loadOfflinePushStatusPaths(
);
-> at com.linkedin.venice.pushmonitor.LeakedPushSta
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 1979274656; memoryAllocatedAfterInstantiations: 1974194592; memoryAllocatedByInstantiations: -5080064; 3 attempts left.
|
|
VeniceOpenTelemetryPerfTest.testTehutiVsOtelMetricRecordingPerf:
internal/venice-client-common/src/test/java/com/linkedin/venice/stats/VeniceOpenTelemetryPerfTest.java#L302
java.lang.AssertionError: OpenTelemetry should not be significantly slower than Tehuti expected [true] but found [false]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 1979274656; memoryAllocatedAfterInstantiations: 1974194592; memoryAllocatedByInstantiations: -5080064; 3 attempts left.
|
|
VeniceOpenTelemetryPerfTest.testTehutiVsOtelMetricRecordingPerf:
internal/venice-client-common/src/test/java/com/linkedin/venice/stats/VeniceOpenTelemetryPerfTest.java#L302
java.lang.AssertionError: OpenTelemetry should not be significantly slower than Tehuti expected [true] but found [false]
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 192 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5eb18af7b8_75e9ff8a_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5eb18af7b8_75e9ff8a_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
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:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1562861346
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1562861346
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5eb18af7b8_75e9ff8a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769821693076},
Mock for Store, hashCode: 1562861346
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5eb18af7b8_75e9ff8a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769821693076}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_5eb18af7b8_75e9ff8a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testDataValidationCheckPointing[0](SORTED, AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_566892c457_17ba7ab5_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 958 interactions with this mock:
logNotifier.started(
"TestTopic_566892c457_17ba7ab5_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:117)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
However, there were exactly 29 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
6.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.083588d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.056417d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.086063d,
1769821853526L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.047881d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2773)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.06327d,
1769821853529L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.054783d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.079379d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.Sto
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 192 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5eb18af7b8_75e9ff8a_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5eb18af7b8_75e9ff8a_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
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:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1562861346
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1562861346
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5eb18af7b8_75e9ff8a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769821693076},
Mock for Store, hashCode: 1562861346
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5eb18af7b8_75e9ff8a_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769821693076}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_5eb18af7b8_75e9ff8a_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testDataValidationCheckPointing[0](SORTED, AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_566892c457_17ba7ab5_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 958 interactions with this mock:
logNotifier.started(
"TestTopic_566892c457_17ba7ab5_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:117)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_566892c457_17ba7ab5_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
However, there were exactly 29 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
6.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.083588d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.056417d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.086063d,
1769821853526L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.047881d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2773)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.06327d,
1769821853529L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1439)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1444)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.054783d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1756)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2145)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.079379d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:783)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.Sto
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
java.util.concurrent.ExecutionException: org.mockito.exceptions.misusing.WrongTypeOfReturnValue:
Long cannot be returned by getIsRunning()
getIsRunning() should return AtomicBoolean
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. This exception *might* occur in wrongly written multi-threaded tests.
Please refer to Mockito FAQ on limitations of concurrency testing.
2. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
java.util.concurrent.ExecutionException: org.mockito.exceptions.misusing.WrongTypeOfReturnValue:
Long cannot be returned by getIsRunning()
getIsRunning() should return AtomicBoolean
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. This exception *might* occur in wrongly written multi-threaded tests.
Please refer to Mockito FAQ on limitations of concurrency testing.
2. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 276 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_444568477a_fa9d7863_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_444568477a_fa9d7863_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 637011117
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 637011117
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_444568477a_fa9d7863_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822624705},
Mock for Store, hashCode: 637011117
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_444568477a_fa9d7863_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822624705}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_444568477a_fa9d7863_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_515bb150ff_1a2fe959_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_515bb150ff_1a2fe959_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 973705156
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 973705156
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_515bb150ff_1a2fe959_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822680898},
Mock for Store, hashCode: 973705156
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_515bb150ff_1a2fe959_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822680898}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_515bb150ff_1a2fe959_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 276 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4589e560e5_1c200351_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4589e560e5_1c200351_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1031226235
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1031226235
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4589e560e5_1c200351_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822630117},
Mock for Store, hashCode: 1031226235
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4589e560e5_1c200351_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822630117}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_4589e560e5_1c200351_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 276 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_444568477a_fa9d7863_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_444568477a_fa9d7863_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 637011117
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 637011117
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_444568477a_fa9d7863_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822624705},
Mock for Store, hashCode: 637011117
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_444568477a_fa9d7863_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822624705}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_444568477a_fa9d7863_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 296 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_515bb150ff_1a2fe959_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_515bb150ff_1a2fe959_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 973705156
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 973705156
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_515bb150ff_1a2fe959_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822680898},
Mock for Store, hashCode: 973705156
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_515bb150ff_1a2fe959_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822680898}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_515bb150ff_1a2fe959_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
|
|
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
leaderFollowerStoreIngestionTask.reportIngestionNotifier(
<any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>,
<any com.linkedin.venice.exceptions.VeniceException>
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612)
However, there were exactly 276 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4589e560e5_1c200351_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4589e560e5_1c200351_v1-1,
true,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755)
leaderFollowerStoreIngestionTask.throwIfNotRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.nextSeqNum();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808)
leaderFollowerStoreIngestionTask.run();
-> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
leaderFollowerStoreIngestionTask.isRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778)
leaderFollowerStoreIngestionTask.getIsRunning();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4536)
leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged(
Mock for Store, hashCode: 1031226235
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781)
leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782)
leaderFollowerStoreIngestionTask.getServerConfig();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5254)
leaderFollowerStoreIngestionTask.getResubscribeRequestQueue();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5255)
leaderFollowerStoreIngestionTask.processConsumerActions(
Mock for Store, hashCode: 1031226235
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4589e560e5_1c200351_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822630117},
Mock for Store, hashCode: 1031226235
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4589e560e5_1c200351_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1769822630117}
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598)
leaderFollowerStoreIngestionTask.getDataIntegrityValidator();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312)
leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5071)
leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica(
PCS{replica=TestTopic_4589e560e5_1c200351_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
Integrations / UT & CodeCov (8)
Back off 25.324 seconds before retry.
|
|
Integrations / UT & CodeCov (8)
Failed to download action 'https://api.github.com/repos/gradle/actions/tarball/ed408507eac070d1f99cc633dbcf757c94c7933a'. Error: The request was canceled due to the configured HttpClient.Timeout of 100 seconds elapsing.
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
Expired
|
926 KB |
sha256:764c8a82cf3c27683ff6c8c0e75c0556e21651f15eb25b68dac8100edaa9cab0
|
|
|
clients-jdk11
Expired
|
3.08 MB |
sha256:0e07eb8a78015cc21c13f40b56d266b417b5bcf52308f6e56cca3057e483e65e
|
|
|
clients-jdk17
Expired
|
3.09 MB |
sha256:d36e96814710d671b7a0ada030d4b42e2fbc40c326ad59b479abf1a63fae27a5
|
|
|
clients-jdk8
Expired
|
3.07 MB |
sha256:e767684fe11c3d2697a9d922911d6afcd533f94684cbcfc45a5273f21268d88f
|
|
|
controller-jdk11
Expired
|
1.99 MB |
sha256:a9f0bbe0eea90d978887fe2ccf3e80abc9eea7c1f06dfda106d2431227748f4f
|
|
|
controller-jdk17
Expired
|
1.98 MB |
sha256:5f8ae1ce9b4f6753dcc608a4dbd89a4758eba2dd981b9f18d3fe39573af34003
|
|
|
controller-jdk8
Expired
|
1.98 MB |
sha256:4cf688205ef3f69afdd07dde82097fc620751a6c97a73d7486238264852eea5d
|
|
|
integrations-jdk11
Expired
|
547 KB |
sha256:8476a4d39f958ba19071478bcd9aab833c746a95d104c5b3405c9a5b3544b6d0
|
|
|
integrations-jdk17
Expired
|
554 KB |
sha256:fcf695aa8766bbcdf5addd12aa85229f318c14c4c8d3c922e80f59b6e1dc2995
|
|
|
integrations-jdk8
Expired
|
535 KB |
sha256:9d00cc6bb47dfb6e475728bfe2ae058103d63c8253fdfc5cf53c35be9e87fb43
|
|
|
internal-jdk11
Expired
|
4.23 MB |
sha256:887c7078e9f49cf9193659ae75434e5fc6ed1ca9e6bd2e301daed929cfe04693
|
|
|
internal-jdk17
Expired
|
4.25 MB |
sha256:04fbbcc6d3dd55f31091761316eefad471bfcf03bd05a83e785279d85c19888c
|
|
|
internal-jdk8
Expired
|
4.22 MB |
sha256:f69abe0a1db30cfdeddc09f834117f2a4004bdc6105d5a03a6bacc066d37a010
|
|
|
router-jdk11
Expired
|
766 KB |
sha256:a4579ee3fdfc4677b3dd3f40c69948f421ad5f176fbad9d57111af4a6aee31d0
|
|
|
router-jdk17
Expired
|
769 KB |
sha256:336f72d66c6ca1959f7e70ec82ccc8160754628e70820e99264eb7c09d213880
|
|
|
router-jdk8
Expired
|
757 KB |
sha256:ff27cec20205913892de1415005af8a2f15c6aa7c5ab193f638bffbca188c5b7
|
|
|
server-jdk11
Expired
|
10.5 MB |
sha256:02733076b8bd9afbac8c8b9c72d685b08706734312573ce108a80c7e219207f5
|
|
|
server-jdk17
Expired
|
10.5 MB |
sha256:ed096c0bb5be6a3a3d3ce85efe6c56f38fcf88f2f1c860acfa41a41602cd5579
|
|
|
server-jdk8
Expired
|
10.2 MB |
sha256:26c6a2141561b4c0d5919d2a3efd6338e88fdeca9f3fbf875e505fabe10d976e
|
|