Skip to content
AnalyseStatiqueEtTestsUnitaires

[server] Switch back to PubSubPosition based reads with offset as fallback #8901

Sign in to view logs

[server] Switch back to PubSubPosition based reads with offset as fallback

[server] Switch back to PubSubPosition based reads with offset as fallback #8901

Triggered via pull request October 28, 2025 20:08
@sushantmanesushantmane
opened #2242
sushantmane:sumane/switch-back-reads-to-PubSubPosition
Status Failure
Total duration 11m 59s
Artifacts 19

VeniceCI-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
41s
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
2s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

42 errors
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 (9.4682) which is too far from the predictedUsage (16); delta: 0.408; maxAllowedDelta: 0.106. 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 (9.4682) which is too far from the predictedUsage (16); delta: 0.408; maxAllowedDelta: 0.106. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L45
java.lang.AssertionError: Class ClassWithTwoPrimitiveShortFields has a memoryAllocatedPerInstance (13.06864) which is too far from the predictedUsage (16); delta: 0.183; maxAllowedDelta: 0.077. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L45
java.lang.AssertionError: Class ClassWithTwoPrimitiveShortFields has a memoryAllocatedPerInstance (13.06864) which is too far from the predictedUsage (16); delta: 0.183; maxAllowedDelta: 0.077. 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#L33
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveByteField has a memoryAllocatedPerInstance (37.07844) which is too far from the predictedUsage (16); delta: 1.317; maxAllowedDelta: 0.027. 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#L33
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveByteField has a memoryAllocatedPerInstance (37.07844) which is too far from the predictedUsage (16); delta: 1.317; maxAllowedDelta: 0.027. No more attempts left.
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF): 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) 0x66, (byte) 0x62, (byte) 0x39, (byte) 0x30, (byte) 0x34, (byte) 0x38, (byte) 0x34, (byte) 0x64, (byte) 0x32, (byte) 0x5F, (byte) 0x66, (byte) 0x35, (byte) 0x33, (byte) 0x33, (byte) 0x63, (byte) 0x32, (byte) 0x35, (byte) 0x33], 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)
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
Server / UT & CodeCov (8)
Process completed with exit code 1.
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
Server / UT & CodeCov (11)
Process completed with exit code 1.
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats: clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L142
java.lang.AssertionError: expected [1000.0] but found [0.0]
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testResetPartition[0](AA_ON): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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) 0x38, (byte) 0x65, (byte) 0x66, (byte) 0x34, (byte) 0x38, (byte) 0x35, (byte) 0x38, (byte) 0x32, (byte) 0x31, (byte) 0x34, (byte) 0x5F, (byte) 0x63, (byte) 0x65, (byte) 0x35, (byte) 0x38, (byte) 0x30, (byte) 0x61, (byte) 0x61, (byte) 0x62], 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)
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
LeaderFollowerStoreIngestionTaskTest.testDeserializePositionWithOffsetFallback: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L896
java.lang.AssertionError: Should return EARLIEST symbolic position expected [EARLIEST] but found [ApacheKafkaOffsetPosition{0}]
Server / UT & CodeCov (17)
Process completed with exit code 1.
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis Expired
920 KB
sha256:e3278102b0b6240c61f408c2937d275d32c1a33284fbe3d0b5feae9f02630d67
clients-jdk11 Expired
2.96 MB
sha256:e3a2b69e1a2232e582d3df4cef05a1ced2a387d3fb743e5f3ed1c60d5bcc4b21
clients-jdk17 Expired
2.98 MB
sha256:ed90ce52174c3e5d9f8cdca7043aa490349c3c2f0dcd3b8156512e3858ce27aa
clients-jdk8 Expired
2.9 MB
sha256:791ed44523f6358f347b5d28c26520894e8a84cb73ed5ee0371a1df13e2c695b
controller-jdk11 Expired
1.98 MB
sha256:5abd801343540a5ad41c61a3139fd1bb386af1f6555a03b636d347e3479e222e
controller-jdk17 Expired
1.94 MB
sha256:211354bbfe4ed5215a80da60166dffcd3cecc764fcbfec027280488a5ce4aba4
controller-jdk8 Expired
1.97 MB
sha256:38cabd7bdb03643cd7aa7b2423871eb4d2d9987a47015171d0889291f1fbf515
integrations-jdk11 Expired
550 KB
sha256:0ea1f7d9978755a03bd308ba6967721f5dddebbc0a220d88134aaffd17714271
integrations-jdk17 Expired
555 KB
sha256:d87f07e9388c44b319e4b68cab04b32fcc574de56bbf03c69dc5b50202e00799
integrations-jdk8 Expired
540 KB
sha256:f88057f61fdd0118bb12f007412118aa7d44ca5b411f989044876bcca546b21c
internal-jdk11 Expired
4.02 MB
sha256:952015b93893cc4e811c1ce185c58a9734d3601584717271c2629d1949a8a25d
internal-jdk17 Expired
4.02 MB
sha256:154111ec503f781918e7f9e7d97efa597300c226eff5d10e429b0b372188a63e
internal-jdk8 Expired
4 MB
sha256:a30128ad6036c64dd42712d56d5cc1ef13e7bd602f0a46112a8eea725058bc3d
router-jdk11 Expired
763 KB
sha256:ace970956a82d92c24602977cdb3ad817c992919f4f9467416bb8e1c7cb23d65
router-jdk17 Expired
766 KB
sha256:be96ecf89e9e48d81e99080c5627211ed6aece96c71f393f7b117ccd16ffea84
router-jdk8 Expired
753 KB
sha256:45f5f28f26625dd01b3cb223917c899e6191590eaa241c695b793ef5490e4fee
server-jdk11 Expired
8.59 MB
sha256:644c0000ed827033fa17407a614a6f57403c3fcb00bffbc6e26a361d22756222
server-jdk17 Expired
8.25 MB
sha256:50a11a16cacfa99b4bf3bdecef89e46f43f22d3982366f5fd32605036df20a95
server-jdk8 Expired
8.37 MB
sha256:6ecf1b9eb436d290d6778d87bb026dcfab45709e2d3a068bf76b3b8997196ec6