[vpj] Fixing a bug with chunked messages in Repush #10127
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
11s
StaticAnalysisAndUnitTestsFailureAlert
Annotations
18 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]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (81.94304) which is too far from the predictedUsage (40); delta: 1.049; maxAllowedDelta: 0.012. No more 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: Class KafkaKey has a memoryAllocatedPerInstance (81.94304) which is too far from the predictedUsage (40); delta: 1.049; maxAllowedDelta: 0.012. No more attempts left.
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testDataValidationCheckPointing[0](SORTED, AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_5fe831d744_a47b3655_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 769 interactions with this mock:
logNotifier.started(
"TestTopic_5fe831d744_a47b3655_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:117)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordTransformerDatabaseChecksumRecordTransformationDisabled[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
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)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testDataValidationCheckPointing[0](SORTED, AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_5fe831d744_a47b3655_v1",
1,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there were exactly 769 interactions with this mock:
logNotifier.started(
"TestTopic_5fe831d744_a47b3655_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:117)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{2}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{3}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{4}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{5}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{6}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{7}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{8}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{9}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{10}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{11}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{12}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{13}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{14}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{15}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportProgress$10(IngestionNotificationDispatcher.java:214)
logNotifier.progress(
"TestTopic_5fe831d744_a47b3655_v1",
1,
InMemoryPubSubPosition{16}
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$re
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordTransformerDatabaseChecksumRecordTransformationDisabled[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
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)
|
|
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:2792)
|
|
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:2792)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testResetPartition[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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) 0x65, (byte) 0x35, (byte) 0x36, (byte) 0x33, (byte) 0x35, (byte) 0x34, (byte) 0x61, (byte) 0x38, (byte) 0x37, (byte) 0x5F, (byte) 0x63, (byte) 0x34, (byte) 0x65, (byte) 0x32, (byte) 0x32, (byte) 0x31, (byte) 0x65, (byte) 0x64],
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.testResetPartition[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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) 0x65, (byte) 0x35, (byte) 0x36, (byte) 0x33, (byte) 0x35, (byte) 0x34, (byte) 0x61, (byte) 0x38, (byte) 0x37, (byte) 0x5F, (byte) 0x63, (byte) 0x34, (byte) 0x65, (byte) 0x32, (byte) 0x32, (byte) 0x31, (byte) 0x65, (byte) 0x64],
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)
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[4](MULTI_GET_STREAMING, false, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[2](MULTI_GET, false, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[4](MULTI_GET_STREAMING, false, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[2](MULTI_GET, false, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
951 KB |
sha256:83bed3080577114d4460e7490cb2c47da5b6e51ca198c04022a8bde3e1458a45
|
|
|
clients-jdk11
|
3.21 MB |
sha256:400762d4887524395cb88b7a2d1414d64e28c34f59c58be8a19bf7db20a5dd0e
|
|
|
clients-jdk17
|
3.23 MB |
sha256:2e05e034d963a88d0c12bad225df80fd6ac5ccc7a67e17a11a95f4f18aa3499d
|
|
|
clients-jdk8
|
3.17 MB |
sha256:beba971a69e8ffea380a4139feb82b7d06d5d24e34ff9d7e8f94e7592bea12f3
|
|
|
controller-jdk11
|
1.97 MB |
sha256:fe87b8563b5e2beac12ef0dc82c7799f662e694833c1aa7061f3ba4a8275467a
|
|
|
controller-jdk17
|
1.96 MB |
sha256:090d86d772644cc91d0bb9b55f12a4e1d9c5b0c4752a6311feec9f20d123de49
|
|
|
controller-jdk8
|
1.96 MB |
sha256:aa7ae067ac9e34bdbf83365f10f0b72f3ddc1ebd89cab9ac6cccab349ef12ae5
|
|
|
integrations-jdk11
|
544 KB |
sha256:45749759563465eec2b36ee040e0055074664a2e9f5ecae685bc2fde0031f2f0
|
|
|
integrations-jdk17
|
550 KB |
sha256:a3c5cdf268b77bcd2b4405e1c4cbeb84710ff3b3bdc56b09209352816aa1c460
|
|
|
integrations-jdk8
|
527 KB |
sha256:6a6c89822f0c02008233304c73a6e6c2c70753e5ee7f04ddf65e5e969f844a16
|
|
|
internal-jdk11
|
4.24 MB |
sha256:8ad14796370bda3cdf8bf87407567a05dcb4b774240f0042af45d6984cdb7052
|
|
|
internal-jdk17
|
4.25 MB |
sha256:cfdf394eec712b84311204a79cdc7f45cb724e3e824b830fde6d28d251b923a0
|
|
|
internal-jdk8
|
4.23 MB |
sha256:427f533d3405898ffb0295c0c62252e422a8d80a9645903f1e952793947aabea
|
|
|
router-jdk11
|
753 KB |
sha256:030f3d4316085738c9da12008d4b4888523eb09be420702d673cc8d3aa4a44c5
|
|
|
router-jdk17
|
758 KB |
sha256:e8f47db8cb3c9aa64c9389d9cbe2014ca2ebe09af4b37f5ed1830932dddc6266
|
|
|
router-jdk8
|
743 KB |
sha256:8dceceafd1235a33b0865d68638cf591dd4fde68b0d11de18665d0f03fc13ebf
|
|
|
server-jdk11
|
10.5 MB |
sha256:7acb3c7cde4cd7a216f8acce2e223a7a6b4329243fc484508f28b6a0a398f835
|
|
|
server-jdk17
|
10.8 MB |
sha256:9fe120c0dbf672b513af8286eeda156fc806a39e74bb45b94343615152bf1c75
|
|
|
server-jdk8
|
10.4 MB |
sha256:7f57b6668675b4bb8fd0a6e51d8af3a1be3b9a9e080cff2ec2c106eb7638618e
|
|