[vpj] Fixing a bug with chunked messages in Repush #10131
ymuppalaVeniceCI-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
12s
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
16 errors
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2400175032; memoryAllocatedAfterInstantiations: 2395619256; memoryAllocatedByInstantiations: -4555776; 3 attempts left.
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2400175032; memoryAllocatedAfterInstantiations: 2395619256; memoryAllocatedByInstantiations: -4555776; 3 attempts left.
|
|
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]
|
|
VeniceChangelogConsumerDaVinciRecordTransformerImplTest.testMaxBufferSize:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImplTest.java#L476
org.mockito.exceptions.verification.TooManyActualInvocations:
conditionObject.signal();
Wanted 1 time:
-> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1938)
But was 2 times:
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.internalAddMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:741)
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.internalAddMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:741)
|
|
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]
|
|
VeniceChangelogConsumerDaVinciRecordTransformerImplTest.testMaxBufferSize:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImplTest.java#L476
org.mockito.exceptions.verification.TooManyActualInvocations:
conditionObject.signal();
Wanted 1 time:
-> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1938)
But was 2 times:
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.internalAddMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:741)
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.internalAddMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:741)
|
|
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]
|
|
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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) 0x37, (byte) 0x38, (byte) 0x64, (byte) 0x31, (byte) 0x62, (byte) 0x61, (byte) 0x32, (byte) 0x65, (byte) 0x30, (byte) 0x5F, (byte) 0x38, (byte) 0x35, (byte) 0x31, (byte) 0x38, (byte) 0x37, (byte) 0x38, (byte) 0x63, (byte) 0x30],
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)
|
|
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:2792)
|
|
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]
|
|
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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) 0x37, (byte) 0x38, (byte) 0x64, (byte) 0x31, (byte) 0x62, (byte) 0x61, (byte) 0x32, (byte) 0x65, (byte) 0x30, (byte) 0x5F, (byte) 0x38, (byte) 0x35, (byte) 0x31, (byte) 0x38, (byte) 0x37, (byte) 0x38, (byte) 0x63, (byte) 0x30],
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)
|
|
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:2792)
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
950 KB |
sha256:a89101ab7eedf65c2d7a82f62b47b3c2ccd5ffbc9e28b355c9a93a0b67f7f641
|
|
|
clients-jdk11
|
3.22 MB |
sha256:ade80fd79797ca800b0916d133d3c75e66ca13941dca6518a6cad5628c027699
|
|
|
clients-jdk17
|
3.23 MB |
sha256:89e92f73598742208206ba35f3ee32b09c3d8eeadb7874e31abc4456cd3a71fa
|
|
|
clients-jdk8
|
3.17 MB |
sha256:ad03e73c43180153eab3ed0cc183897e16b1a2094aa9b4112878f7b828063ed2
|
|
|
controller-jdk11
|
1.97 MB |
sha256:c77049582717acb62752474845b880f4f94769814af0c2842dc91b79559f17af
|
|
|
controller-jdk17
|
1.97 MB |
sha256:89d85d2839055cebe7a9ef80a050fa86d6e82e56937ba2559230188420740a01
|
|
|
controller-jdk8
|
1.95 MB |
sha256:ca145c43a3cbe6a120bd47c23adac5e55024e003d42b81cdb005135c3ff29ef7
|
|
|
integrations-jdk11
|
539 KB |
sha256:353cf08c4ad519da8734312153062a3e7b87954e93e4a9840b40670f6738db85
|
|
|
integrations-jdk17
|
547 KB |
sha256:9f341d147ad509a487d5442e6a886e4697f69f354bd0e716e957e80fd99af3e3
|
|
|
integrations-jdk8
|
528 KB |
sha256:2c6f9276953638c247562743fc833ff101b8a1989fe7c98f2b58288414916a43
|
|
|
internal-jdk11
|
4.24 MB |
sha256:f74fde3c3c09999ad49ce6e1d38fa3c4a7c873129abfe04628cfd52597d29149
|
|
|
internal-jdk17
|
4.25 MB |
sha256:378282910308de2f397dd28ebe4aea968e5010c2bfc5b78f3f5aff9e95d094b2
|
|
|
internal-jdk8
|
4.23 MB |
sha256:8a8e354cb8cd7b78d19f9b7897052d5fbd9955b19f4c5a74f74e0cc74f71f49e
|
|
|
router-jdk11
|
754 KB |
sha256:262138efd96f72957097587203215b8017c3f4eb9057116103168ed42bd87a7a
|
|
|
router-jdk17
|
755 KB |
sha256:8fa13fcdd8836939bead5b116d8703530a959218a65a39a1f8e4d22d29ed3d89
|
|
|
router-jdk8
|
744 KB |
sha256:43091a187a847a131ae5cc830ca7f9bd3da881737f042595b10f676bfa501ffa
|
|
|
server-jdk11
|
10.8 MB |
sha256:b4630cf46464f75f529716e2dfd89e384299a57e5878f318b731cbbbb1f88817
|
|
|
server-jdk17
|
10.6 MB |
sha256:b959dbefbdd0d552417f03ad5a6f03ab70babc5bb8a519d815f651a5a2502d23
|
|
|
server-jdk8
|
10.1 MB |
sha256:307c78685c361c30f2fd8e30485cea85f2ede552415a7c960f683c62456e6baf
|
|