[controller] Account for max read capacity in quota change #8932
misyelVeniceCI-StaticAnalysisAndUnitTests.yml
on: pull_request
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
10s
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
24 errors
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L36
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveIntField has a memoryAllocatedPerInstance (26.78364) which is too far from the predictedUsage (16); delta: 0.674; maxAllowedDelta: 0.037. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L36
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveIntField has a memoryAllocatedPerInstance (26.78364) which is too far from the predictedUsage (16); delta: 0.674; maxAllowedDelta: 0.037. No more attempts left.
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (37.37856) which is too far from the predictedUsage (40); delta: 0.066; maxAllowedDelta: 0.027. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L29
java.lang.AssertionError: Class SubclassOfObjectWithNoFields has a memoryAllocatedPerInstance (24.02912) which is too far from the predictedUsage (16); delta: 0.502; maxAllowedDelta: 0.042. No more attempts left.
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (37.37856) which is too far from the predictedUsage (40); delta: 0.066; maxAllowedDelta: 0.027. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L29
java.lang.AssertionError: Class SubclassOfObjectWithNoFields has a memoryAllocatedPerInstance (24.02912) which is too far from the predictedUsage (16); delta: 0.502; maxAllowedDelta: 0.042. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L29
java.lang.AssertionError: Class SubclassOfObjectWithNoFields has a memoryAllocatedPerInstance (22.95128) which is too far from the predictedUsage (16); delta: 0.434; maxAllowedDelta: 0.044. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L29
java.lang.AssertionError: Class SubclassOfObjectWithNoFields has a memoryAllocatedPerInstance (22.95128) which is too far from the predictedUsage (16); delta: 0.434; maxAllowedDelta: 0.044. No more attempts left.
|
|
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:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
|
|
ParticipantStoreConsumptionTaskTest.testOverallRunFlow:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/ParticipantStoreConsumptionTaskTest.java#L114
org.mockito.exceptions.verification.TooFewActualInvocations:
storeIngestionService.getIngestingTopicsWithVersionStatusNotOnline();
Wanted 3 times:
-> at com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTaskTest.testOverallRunFlow(ParticipantStoreConsumptionTaskTest.java:114)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask.run(ParticipantStoreConsumptionTask.java:101)
-> at com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask.run(ParticipantStoreConsumptionTask.java:101)
|
|
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:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
|
|
ParticipantStoreConsumptionTaskTest.testOverallRunFlow:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/ParticipantStoreConsumptionTaskTest.java#L114
org.mockito.exceptions.verification.TooFewActualInvocations:
storeIngestionService.getIngestingTopicsWithVersionStatusNotOnline();
Wanted 3 times:
-> at com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTaskTest.testOverallRunFlow(ParticipantStoreConsumptionTaskTest.java:114)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask.run(ParticipantStoreConsumptionTask.java:101)
-> at com.linkedin.davinci.kafka.consumer.ParticipantStoreConsumptionTask.run(ParticipantStoreConsumptionTask.java:101)
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
However, there were exactly 30 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
8.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.004809d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.002896d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.075291d,
1761772363723L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.002013d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.052779d,
1761772363725L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2653)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.002515d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.042108d,
1761772363736L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.Stor
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
However, there were exactly 30 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
8.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.004809d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.002896d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.075291d,
1761772363723L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.002013d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.052779d,
1761772363725L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2653)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.002515d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.042108d,
1761772363736L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.Stor
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L149
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
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:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
abstractStorageEngine.put(
1,
[(byte) 0x01, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x31, (byte) 0x5F, (byte) 0x31, (byte) 0x64, (byte) 0x39, (byte) 0x64, (byte) 0x30, (byte) 0x61, (byte) 0x34, (byte) 0x37, (byte) 0x39, (byte) 0x64, (byte) 0x5F, (byte) 0x33, (byte) 0x32, (byte) 0x65, (byte) 0x39, (byte) 0x38, (byte) 0x61, (byte) 0x38, (byte) 0x36],
java.nio.HeapByteBuffer[pos=0 lim=17 cap=17]
);
Wanted 2 times:
-> at com.linkedin.davinci.store.AbstractStorageEngine.put(AbstractStorageEngine.java:478)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
|
|
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:507)
However, there were exactly 33 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
9.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.010409d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.007715d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.101099d,
1761772374000L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.056366d,
1761772374004L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.007554d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2653)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.007514d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.04834d,
1761772374018L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.Store
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L149
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
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:507)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
abstractStorageEngine.put(
1,
[(byte) 0x01, (byte) 0x4B, (byte) 0x65, (byte) 0x79, (byte) 0x46, (byte) 0x6F, (byte) 0x72, (byte) 0x50, (byte) 0x61, (byte) 0x72, (byte) 0x74, (byte) 0x69, (byte) 0x74, (byte) 0x69, (byte) 0x6F, (byte) 0x6E, (byte) 0x31, (byte) 0x5F, (byte) 0x31, (byte) 0x64, (byte) 0x39, (byte) 0x64, (byte) 0x30, (byte) 0x61, (byte) 0x34, (byte) 0x37, (byte) 0x39, (byte) 0x64, (byte) 0x5F, (byte) 0x33, (byte) 0x32, (byte) 0x65, (byte) 0x39, (byte) 0x38, (byte) 0x61, (byte) 0x38, (byte) 0x36],
java.nio.HeapByteBuffer[pos=0 lim=17 cap=17]
);
Wanted 2 times:
-> at com.linkedin.davinci.store.AbstractStorageEngine.put(AbstractStorageEngine.java:478)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2661)
|
|
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:507)
However, there were exactly 33 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
9.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.010409d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.007715d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.101099d,
1761772374000L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.056366d,
1761772374004L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.007554d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2653)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2058)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.007514d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:779)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1673)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.04834d,
1761772374018L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1371)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1376)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.Store
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
920 KB |
sha256:50ec9ee83c25ebef1902a18422f7d1e0a5dc7960e17799aa83e9420d544000b3
|
|
|
clients-jdk11
|
2.94 MB |
sha256:13daf827e28f0f33421b033eb88fb4d1973bde375176d4498afc89ea59309f8f
|
|
|
clients-jdk17
|
2.97 MB |
sha256:78e1924c38a7c1c85681640f7c48ae3d9b92ab953bb7eef9355f5572a0e1c3af
|
|
|
clients-jdk8
|
2.89 MB |
sha256:d031fd385174c37bb47b6466256ff83ca663eb315d6c03c38c1d0ba5800a98d3
|
|
|
controller-jdk11
|
1.98 MB |
sha256:9cc4867f833a6d0dc42b8a490618e2ed59eb98e31862a23c3fa9789c20742ad4
|
|
|
controller-jdk17
|
1.96 MB |
sha256:9141c94740c245784ec1f3ea1cc5f7e289454dafc4a7d7adc393c6ff276c5054
|
|
|
controller-jdk8
|
1.99 MB |
sha256:be6ded56c36da45d23eb5c2a30487cd0522b2da458a9ee053f219c8597fcde63
|
|
|
integrations-jdk11
|
550 KB |
sha256:6b4925d081719f03c28bad94ce1fd6ac78c3076a1018cb94e206f3f18cd793d9
|
|
|
integrations-jdk17
|
553 KB |
sha256:898978722126f03f35eaaa11bfcb55077df6f9a9a27e544fb701377387ffab45
|
|
|
integrations-jdk8
|
533 KB |
sha256:255976730d08eb459aafaa8200ada6df4fff4442f418896c1f65c82eb257ef3a
|
|
|
internal-jdk11
|
4.01 MB |
sha256:d98b65dcd3a525b6d0da20d2a5061f6782a90c4c18fcac3a9da426b8edffa13b
|
|
|
internal-jdk17
|
4.02 MB |
sha256:e30501db818ce009fb2c5893a1047ac80bc157c50a4ba2bfa1fee65011a9e5d9
|
|
|
internal-jdk8
|
3.99 MB |
sha256:a27bf3dd2fcfb5ae80c25d8e2ea0ab2ed1e850439e9378d88502d5f9aa787cff
|
|
|
router-jdk11
|
770 KB |
sha256:3eaf241dc519c602c4ae9deebda4dddc850ac9c37f5462c6aafa3ecda6976d5c
|
|
|
router-jdk17
|
776 KB |
sha256:4f9c71ba416312478c114b71f561ceb98735efced9f9697dfd5e0266ac1014d7
|
|
|
router-jdk8
|
764 KB |
sha256:5978abae19903698f0466a596f2b14422d8969f447da875c8bfc6e6a63ecc6e9
|
|
|
server-jdk11
|
10.3 MB |
sha256:472a3974857a3806fa376ba3c3783c3be9d6184c5b40996cbb308d6935b1fcb2
|
|
|
server-jdk17
|
10.1 MB |
sha256:958f59fade295f84ae94acaaaf97d74c455e37dc91f5ec8bf53544ef028bafed
|
|
|
server-jdk8
|
10.1 MB |
sha256:03d8fc14c4c9c335184bda862eadb15b42d57a46addbb876ad100361ea2c6e87
|
|