[venice-common] Add VeniceComponent to the PubSubAdminAdapterContext #9141
sofiaz11VeniceCI-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
12 errors
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L34
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveCharField has a memoryAllocatedPerInstance (4.83424) which is too far from the predictedUsage (16); delta: 0.698; maxAllowedDelta: 0.207. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L34
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveCharField has a memoryAllocatedPerInstance (4.83424) which is too far from the predictedUsage (16); delta: 0.698; maxAllowedDelta: 0.207. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L44
java.lang.AssertionError: Class ClassWithTwoPrimitiveCharFields has a memoryAllocatedPerInstance (13.92248) which is too far from the predictedUsage (16); delta: 0.130; maxAllowedDelta: 0.072. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L44
java.lang.AssertionError: Class ClassWithTwoPrimitiveCharFields has a memoryAllocatedPerInstance (13.92248) which is too far from the predictedUsage (16); delta: 0.130; maxAllowedDelta: 0.072. 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#L35
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveShortField has a memoryAllocatedPerInstance (31.2346) which is too far from the predictedUsage (16); delta: 0.952; maxAllowedDelta: 0.032. 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#L35
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveShortField has a memoryAllocatedPerInstance (31.2346) which is too far from the predictedUsage (16); delta: 0.952; maxAllowedDelta: 0.032. No more attempts left.
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
However, there were exactly 27 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
7.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.00511d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.003297d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.12943d,
1762996671757L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1386)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1391)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.003246d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.110427d,
1762996671759L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1386)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1391)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2693)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.003366d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.06275700000000001d,
1762996671770L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1386)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1391)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
However, there were exactly 27 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
7.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.00511d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.003297d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.12943d,
1762996671757L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1386)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1391)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.003246d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.110427d,
1762996671759L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1386)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1391)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2693)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2075)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.003366d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:778)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1688)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.06275700000000001d,
1762996671770L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1386)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1391)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
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 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:2701)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
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 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:2701)
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
922 KB |
sha256:bdba07e236e8022ef99709436ab31f18bcf4cb8bf0da85f9d5a916ffdab28d9b
|
|
|
clients-jdk11
|
2.93 MB |
sha256:5b9c4fa059f81322c272c5e476ff0b73825180b3f4e7236eef7f722a0b7a2421
|
|
|
clients-jdk17
|
2.96 MB |
sha256:d61e22213a6b24f0f0088bdf60977c17d47c8eed5eb29aad197ea597588fc080
|
|
|
clients-jdk8
|
2.88 MB |
sha256:582d7b40f8c22bf24b9d79cf38f62c08d036fbe6b765fca659cbd805288cf13c
|
|
|
controller-jdk11
|
1.98 MB |
sha256:ee3a6e0bb91f89ef51de9a471af6d132df11feee1cc918acb382e1c52f64b10f
|
|
|
controller-jdk17
|
1.96 MB |
sha256:9fe183553647230ba391e823800318f17beef04bf5f00a0823a59235097248d1
|
|
|
controller-jdk8
|
1.98 MB |
sha256:fbc134ded5431fab12f38cebabe6d9b7c27bf23fc30bc6572ae0db0a506c5e59
|
|
|
integrations-jdk11
|
535 KB |
sha256:8726580d774318a032a3d19539f58c89f991dfc926cdc240ad33a3af5a191936
|
|
|
integrations-jdk17
|
545 KB |
sha256:fe25def288a56f8b6431b9f819b8f7b68c310107e85c098984c95879b435451e
|
|
|
integrations-jdk8
|
526 KB |
sha256:927bf04ad76e4071a17ffd151051e3172ca7481ca84c3416beb1c0298a7ff826
|
|
|
internal-jdk11
|
4.05 MB |
sha256:98b8635c7c067989ef69a5d3c407290a1323b2035eb34d2e212ffde2d9d03022
|
|
|
internal-jdk17
|
4.06 MB |
sha256:1fc56a144293ae0fe283ff8cb32cdfad68c5f39f06825ec641c1fc9b1dcbfcb6
|
|
|
internal-jdk8
|
4.04 MB |
sha256:1d287a893be62c1c703695cc16559dfec187ca46d818b7a31c3a8dd9b1b6c374
|
|
|
router-jdk11
|
762 KB |
sha256:01bc71cee55f3e9090ba4e13477fbf08d2ae7bbae55bac94a62482a22e8afce1
|
|
|
router-jdk17
|
769 KB |
sha256:2acf34ef7c242b7a8c54370e2e2acc3351ccc5c9bd78babf410d8a02f402eb47
|
|
|
router-jdk8
|
756 KB |
sha256:f88b95a8c640b4df2c5b4e7b42ed4533b9589cd1009bf96726e5c85b6a58527d
|
|
|
server-jdk11
|
10.3 MB |
sha256:2f78ab3c067051979a0f0e1a769d64268efef8b00cf3113660b64b571f7ef5b2
|
|
|
server-jdk17
|
10.3 MB |
sha256:ea3885af0819850184e828de992827d4b7fa022cd8a80e5711a24b64c54b5fc9
|
|
|
server-jdk8
|
9.91 MB |
sha256:c7c8d68f68167afbb9e415c2547ca58f9d526b4e46cb02b053200f5142dc32c9
|
|