[admin-tool] update VeniceKafkaDecodedRecord with PubSubPosition field #9161
arjun4084346VeniceCI-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
11s
StaticAnalysisAndUnitTestsFailureAlert
Annotations
22 errors
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (45.37856) which is too far from the predictedUsage (48); delta: 0.055; maxAllowedDelta: 0.022. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L26
java.lang.AssertionError: Class Object has a memoryAllocatedPerInstance (8.47848) which is too far from the predictedUsage (16); delta: 0.470; maxAllowedDelta: 0.118. 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 (45.37856) which is too far from the predictedUsage (48); delta: 0.055; maxAllowedDelta: 0.022. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L26
java.lang.AssertionError: Class Object has a memoryAllocatedPerInstance (8.47848) which is too far from the predictedUsage (16); delta: 0.470; maxAllowedDelta: 0.118. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L26
java.lang.AssertionError: Class Object has a memoryAllocatedPerInstance (29.82516) which is too far from the predictedUsage (16); delta: 0.864; maxAllowedDelta: 0.034. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L26
java.lang.AssertionError: Class Object has a memoryAllocatedPerInstance (29.82516) which is too far from the predictedUsage (16); delta: 0.864; maxAllowedDelta: 0.034. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L54
java.lang.AssertionError: Class SubClassWithTwoPrimitiveBooleanFields has a memoryAllocatedPerInstance (26.01852) which is too far from the predictedUsage (24); delta: 0.084; maxAllowedDelta: 0.038. No more attempts left.
|
|
HttpClient5Test.testWithH2CompatibleAPI:
internal/venice-client-common/src/test/java/com/linkedin/venice/httpclient5/HttpClient5Test.java#L192
java.lang.AssertionError: Request timed out
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L54
java.lang.AssertionError: Class SubClassWithTwoPrimitiveBooleanFields has a memoryAllocatedPerInstance (26.01852) which is too far from the predictedUsage (24); delta: 0.084; maxAllowedDelta: 0.038. No more attempts left.
|
|
HttpClient5Test.testWithH2CompatibleAPI:
internal/venice-client-common/src/test/java/com/linkedin/venice/httpclient5/HttpClient5Test.java#L192
java.lang.AssertionError: Request timed out
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
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 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:2701)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2701)
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
VeniceChangelogConsumerDaVinciRecordTransformerImplTest.testMaxBufferSize:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImplTest.java#L476
Wanted but not invoked:
conditionObject.signal();
-> at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1476)
However, there was exactly 1 interaction with this mock:
conditionObject.await(100L, MILLISECONDS);
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl.poll(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:398)
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
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 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:2701)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2701)
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
VeniceChangelogConsumerDaVinciRecordTransformerImplTest.testMaxBufferSize:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImplTest.java#L476
Wanted but not invoked:
conditionObject.signal();
-> at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1476)
However, there was exactly 1 interaction with this mock:
conditionObject.await(100L, MILLISECONDS);
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl.poll(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:398)
|
|
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:2701)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2701)
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L497
com.linkedin.venice.exceptions.VeniceException: Subscribe to new topic:_6b61da2e05_75938f3b_v1 is not successful, error: java.util.concurrent.ExecutionException: java.lang.IllegalThreadStateException
|
|
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:2701)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2701)
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L497
com.linkedin.venice.exceptions.VeniceException: Subscribe to new topic:_6b61da2e05_75938f3b_v1 is not successful, error: java.util.concurrent.ExecutionException: java.lang.IllegalThreadStateException
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
923 KB |
sha256:33a980cab1056d3e43e1b1387df9f668b1f2f33c7db30f3956dd27c3e6bf9a5f
|
|
|
clients-jdk11
|
2.93 MB |
sha256:ce19f61da66a8060d92e10110830b1d2bc3db1d5afa8eed47a07a4762994aff9
|
|
|
clients-jdk17
|
2.97 MB |
sha256:5a8be12e7d26b853508c5d38747b3e3d084b5c730146b29420c7390f926cd399
|
|
|
clients-jdk8
|
2.89 MB |
sha256:c5dc7ebfa411295a2bc9ff02daa9b86521635d681476053386476216f27e9db7
|
|
|
controller-jdk11
|
1.95 MB |
sha256:1af712c68859748da10ed943d819cf813e7b5502619b45fa9f2d5b663369437b
|
|
|
controller-jdk17
|
1.94 MB |
sha256:512ac10eb9d2ad05a4c8fb5186a01b02dd54848fd47a7bf0888214b61e0cc394
|
|
|
controller-jdk8
|
1.94 MB |
sha256:980e12809e3d7c2c1973784b69326dbfb0aa3bbd40159531f0037257cd237f54
|
|
|
integrations-jdk11
|
531 KB |
sha256:63afc1771b1d77a911ddead2c8440f310b117a32231f326407c2eb0a2b27cabf
|
|
|
integrations-jdk17
|
539 KB |
sha256:859fa76d57ed609bad2266dcdeaef16999f9af2995c58a39d931219678e1e3a5
|
|
|
integrations-jdk8
|
521 KB |
sha256:dda22d1bf77c47b52ead069649214808344ba4c52d292c15794d848fe4d3f036
|
|
|
internal-jdk11
|
4.04 MB |
sha256:1a3227ef7917496afd54b4539e48b5c2a2e246b22ca41ec594cc9c59702c6d3e
|
|
|
internal-jdk17
|
4.05 MB |
sha256:4a17288e5fe36ef0f8bdae6b2dbadff1c5712d40509cd380dab579ea79c5cce6
|
|
|
internal-jdk8
|
4.02 MB |
sha256:cd1103bffa36f7a6a6ab3f68ce14c452caf4f6edcb0d06b67a09e9240f1bdea6
|
|
|
router-jdk11
|
762 KB |
sha256:139a46dd09c357b3dfd12a4e484c87377002264ec301ae46009d2008604f5ed6
|
|
|
router-jdk17
|
769 KB |
sha256:32e2c88ee923fb8ce84fc6712cfe4752b3d753ec48d5f1dda185493b11994e4a
|
|
|
router-jdk8
|
753 KB |
sha256:ee6882289dd205c2475816de74ccbc756d3ac198f09d920823786bb5acc1ef77
|
|
|
server-jdk11
|
10.4 MB |
sha256:3e19023ee3084714fa6c42af620cbe727043550ec2f4a62e2f603ad2a2fe7684
|
|
|
server-jdk17
|
10.3 MB |
sha256:bd20cf58dd4287359b64672da7856cb6939a07ad4e7f23b53dc99a8ef42aa6fa
|
|
|
server-jdk8
|
10 MB |
sha256:6d749f4160b09cb7ca65e9a9b4e0fc74f1730bc49e19ea47a727365c360abff6
|
|