Skip to content

[server] [config] Revert Configurable Increased Max Wait After Unsubscribe #9283

[server] [config] Revert Configurable Increased Max Wait After Unsubscribe

[server] [config] Revert Configurable Increased Max Wait After Unsubscribe #9283

Triggered via pull request November 24, 2025 23:37
Status Success
Total duration 12m 8s
Artifacts 19
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
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
0s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

24 errors
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#L37
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveFloatField has a memoryAllocatedPerInstance (30.35676) which is too far from the predictedUsage (16); delta: 0.897; maxAllowedDelta: 0.033. 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#L37
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveFloatField has a memoryAllocatedPerInstance (30.35676) which is too far from the predictedUsage (16); delta: 0.897; maxAllowedDelta: 0.033. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L47
java.lang.AssertionError: Class ClassWithTwoPrimitiveFloatFields has a memoryAllocatedPerInstance (25.98788) which is too far from the predictedUsage (24); delta: 0.083; maxAllowedDelta: 0.038. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L47
java.lang.AssertionError: Class ClassWithTwoPrimitiveFloatFields has a memoryAllocatedPerInstance (25.98788) which is too far from the predictedUsage (24); delta: 0.083; maxAllowedDelta: 0.038. No more attempts left.
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L144
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.venice.controller.TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl(TestVeniceParentHelixAdminWithAcl.java:144) E.g. thenReturn() may be missing. Examples of correct stubbing: when(mock.isOk()).thenReturn(true); when(mock.isOk()).thenThrow(exception); doThrow(exception).when(mock).someVoidMethod(); Hints: 1. missing thenReturn() 2. you are trying to stub a final method, which is not supported 3. you are stubbing the behaviour of another mock inside before 'thenReturn' instruction is completed
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L149
java.lang.AssertionError: ACLs were not properly cleared on deleteAclForStore. Actual: {Resource:test-store-authorizer, [{Principal:user:user2, Method:Read, Permission:ALLOW}{Principal:group:group2, Method:Read, Permission:ALLOW}{Principal:service:app2, Method:Read, Permission:ALLOW}{Principal:user:user2, Method:Write, Permission:ALLOW}{Principal:group:group2, Method:Write, Permission:ALLOW}{Principal:service:app2, Method:Write, Permission:ALLOW}{Principal:user:denyuser1, Method:Read, Permission:DENY}]}, Expected: {Resource:test-store-authorizer, []} expected [true] but found [false]
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L144
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.venice.controller.TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl(TestVeniceParentHelixAdminWithAcl.java:144) E.g. thenReturn() may be missing. Examples of correct stubbing: when(mock.isOk()).thenReturn(true); when(mock.isOk()).thenThrow(exception); doThrow(exception).when(mock).someVoidMethod(); Hints: 1. missing thenReturn() 2. you are trying to stub a final method, which is not supported 3. you are stubbing the behaviour of another mock inside before 'thenReturn' instruction is completed
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L149
java.lang.AssertionError: ACLs were not properly cleared on deleteAclForStore. Actual: {Resource:test-store-authorizer, [{Principal:user:user2, Method:Read, Permission:ALLOW}{Principal:group:group2, Method:Read, Permission:ALLOW}{Principal:service:app2, Method:Read, Permission:ALLOW}{Principal:user:user2, Method:Write, Permission:ALLOW}{Principal:group:group2, Method:Write, Permission:ALLOW}{Principal:service:app2, Method:Write, Permission:ALLOW}{Principal:user:denyuser1, Method:Read, Permission:DENY}]}, Expected: {Resource:test-store-authorizer, []} expected [true] but found [false]
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 (17.5904) which is too far from the predictedUsage (16); delta: 0.099; maxAllowedDelta: 0.057. 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 (17.5904) which is too far from the predictedUsage (16); delta: 0.099; maxAllowedDelta: 0.057. No more attempts left.
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:507) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
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:507) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
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:507) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
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:507) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
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:507) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
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:507) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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:2739) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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:2739)
SITWithPWiseWithoutBufferAfterLeaderTest.testResubscribeAfterRoleChange: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: abstractStorageEngine.putWithReplicationMetadata( 1, <any>, <any>, <any> ); -> at com.linkedin.davinci.store.AbstractStorageEngine.putWithReplicationMetadata(AbstractStorageEngine.java:487) However, there were exactly 415 interactions with this mock: abstractStorageEngine.getStoreVersionState(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getStoreVersionState(DelegatingStorageEngine.java:274) abstractStorageEngine.getPartitionOrThrow(1); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.getPartitionOrThrow(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.beginBatchWrite( Replica: TestTopic_cd7a3a8ac4_7e9922ad_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false, {}, Optional.empty ); -> at com.linkedin.davinci.store.DelegatingStorageEngine.beginBatchWrite(DelegatingStorageEngine.java:317) abstractStorageEngine.isClosed(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.isClosed(DelegatingStorageEngine.java:165) abstractStorageEngine.sync(1); -> at com.linkedin.davinci.store.DelegatingStorageEngine.sync(DelegatingStorageEngine.java:155) abstractStorageEngine.getPartitionOrThrow(1); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.beginBatchWrite( Replica: TestTopic_cd7a3a8ac4_7e9922ad_v1-2, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false, {}, Optional.empty ); -> at com.linkedin.davinci.store.DelegatingStorageEngine.beginBatchWrite(DelegatingStorageEngine.java:317) abstractStorageEngine.isClosed(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.isClosed(DelegatingStorageEngine.java:165) abstractStorageEngine.sync(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.sync(DelegatingStorageEngine.java:155) abstractStorageEngine.getPartitionOrThrow(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.put( 2, [(byte) 0x02, (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) 0x32, (byte) 0x5F, (byte) 0x39, (byte) 0x33, (byte) 0x65, (byte) 0x33, (byte) 0x64, (byte) 0x36, (byte) 0x35, (byte) 0x65, (byte) 0x37, (byte) 0x64, (byte) 0x5F, (byte) 0x35, (byte) 0x35, (byte) 0x31, (byte) 0x61, (byte) 0x31, (byte) 0x30, (byte) 0x66, (byte) 0x36, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00], java.nio.HeapByteBuffer[pos=0 lim=21 cap=21] ); -> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39) abstractStorageEngine.isClosed(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.isClosed(DelegatingStorageEngine.java:165) abstractStorageEngine.sync(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.sync(DelegatingStorageEngine.java:155) abstractStorageEngine.getPartitionOrThrow(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.put( 2, [(byte) 0x02, (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) 0x32, (byte) 0x5F, (byte) 0x39, (byte) 0x33, (byte) 0x65, (byte) 0x33, (byte) 0x64, (byte) 0x36, (byte) 0x35, (byte) 0x65, (byte) 0x37, (byte) 0x64, (byte) 0x5F, (byte) 0x35, (byte) 0x35, (byte) 0x31, (byte) 0x61, (byte) 0x31, (byte) 0x30, (byte) 0x66, (byte) 0x36, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x01], java.nio.HeapByteBuffer[pos=0 lim=21 c
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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:2739) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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:2739)
SITWithPWiseWithoutBufferAfterLeaderTest.testResubscribeAfterRoleChange: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: abstractStorageEngine.putWithReplicationMetadata( 1, <any>, <any>, <any> ); -> at com.linkedin.davinci.store.AbstractStorageEngine.putWithReplicationMetadata(AbstractStorageEngine.java:487) However, there were exactly 415 interactions with this mock: abstractStorageEngine.getStoreVersionState(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getStoreVersionState(DelegatingStorageEngine.java:274) abstractStorageEngine.getPartitionOrThrow(1); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.getPartitionOrThrow(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.beginBatchWrite( Replica: TestTopic_cd7a3a8ac4_7e9922ad_v1-1, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false, {}, Optional.empty ); -> at com.linkedin.davinci.store.DelegatingStorageEngine.beginBatchWrite(DelegatingStorageEngine.java:317) abstractStorageEngine.isClosed(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.isClosed(DelegatingStorageEngine.java:165) abstractStorageEngine.sync(1); -> at com.linkedin.davinci.store.DelegatingStorageEngine.sync(DelegatingStorageEngine.java:155) abstractStorageEngine.getPartitionOrThrow(1); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.beginBatchWrite( Replica: TestTopic_cd7a3a8ac4_7e9922ad_v1-2, deferred-write: false, read-only: false, write-only: true, read-write leader for default CF: false, read-write leader for RMD CF: false, {}, Optional.empty ); -> at com.linkedin.davinci.store.DelegatingStorageEngine.beginBatchWrite(DelegatingStorageEngine.java:317) abstractStorageEngine.isClosed(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.isClosed(DelegatingStorageEngine.java:165) abstractStorageEngine.sync(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.sync(DelegatingStorageEngine.java:155) abstractStorageEngine.getPartitionOrThrow(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.put( 2, [(byte) 0x02, (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) 0x32, (byte) 0x5F, (byte) 0x39, (byte) 0x33, (byte) 0x65, (byte) 0x33, (byte) 0x64, (byte) 0x36, (byte) 0x35, (byte) 0x65, (byte) 0x37, (byte) 0x64, (byte) 0x5F, (byte) 0x35, (byte) 0x35, (byte) 0x31, (byte) 0x61, (byte) 0x31, (byte) 0x30, (byte) 0x66, (byte) 0x36, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00], java.nio.HeapByteBuffer[pos=0 lim=21 cap=21] ); -> at com.linkedin.davinci.kafka.consumer.DeepCopyStorageEngine.put(DeepCopyStorageEngine.java:39) abstractStorageEngine.isClosed(); -> at com.linkedin.davinci.store.DelegatingStorageEngine.isClosed(DelegatingStorageEngine.java:165) abstractStorageEngine.sync(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.sync(DelegatingStorageEngine.java:155) abstractStorageEngine.getPartitionOrThrow(2); -> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294) abstractStorageEngine.put( 2, [(byte) 0x02, (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) 0x32, (byte) 0x5F, (byte) 0x39, (byte) 0x33, (byte) 0x65, (byte) 0x33, (byte) 0x64, (byte) 0x36, (byte) 0x35, (byte) 0x65, (byte) 0x37, (byte) 0x64, (byte) 0x5F, (byte) 0x35, (byte) 0x35, (byte) 0x31, (byte) 0x61, (byte) 0x31, (byte) 0x30, (byte) 0x66, (byte) 0x36, (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x01], java.nio.HeapByteBuffer[pos=0 lim=21 c

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis
922 KB
sha256:c2d848eea68d6de5d7b7aca865c8a4b3f8a08b846734f6054ba5cc09ad0a1741
clients-jdk11
2.94 MB
sha256:c857db98eeec0e0bd123d2a54c5e468a7ea729d3d2295857e8199a0292c9a7d5
clients-jdk17
2.97 MB
sha256:478e32c6e0c1a150f7655313917f02c0de984058dd4c93c4683d75e3452b2eb5
clients-jdk8
2.9 MB
sha256:29cc22efed73ca7fca9ba392ebd3b977beb9475139b3d86e00c0e5570e46d2b6
controller-jdk11
1.98 MB
sha256:05d55b795d3622500aa7f5b89d925b92200c2c9260e9a0cc4e2d3eab3d962c6c
controller-jdk17
1.98 MB
sha256:a2d3ac184aa6c8a2bddaf6b5ac953b93d3158696bb191ec93de2db776ae04681
controller-jdk8
1.99 MB
sha256:df3938b807302dbb298765296e079821cc8cf26f5f51bcf5b7206d27f103b9ee
integrations-jdk11
538 KB
sha256:459bbabb7fd22ef59c0a59fe62d47600bcc9e5a1cbdd7aa8c7bd1bb10553622f
integrations-jdk17
545 KB
sha256:f448be4f9d6d645952ae99ce1ca0156360d141d93cdcd354d074d883bbbfd22b
integrations-jdk8
528 KB
sha256:7ea53fc8dfa670c68f82111048b053220b3dfc61cccc7a0a27889f8e3d8a86c9
internal-jdk11
4.04 MB
sha256:ca11c2c6415fdeee9b6df6274d1514c551bf97bafccb50229876e2ea7fdcff59
internal-jdk17
4.05 MB
sha256:88f06590afab61ccccc9cf7037a4a323cff44a623b296af7db9c72dad03d5f0a
internal-jdk8
4.03 MB
sha256:e1ac9ae7eefcfecf15f92ec0d58b36c2b95749215d29671bb7fbe279706072f3
router-jdk11
763 KB
sha256:0aebd7ed7b611482a258bed52150b3d9dd12f90c0a813871003600f7653a018b
router-jdk17
770 KB
sha256:d69d508e957e61869050055ae715685a885c242d22da8399e227900a9ebb6995
router-jdk8
753 KB
sha256:3eb1f6a395cf9bf8496ccbf002239fe23798c8ec31514e439ba94293bdb6ad60
server-jdk11
10.5 MB
sha256:d7bfde4061ab70c4568d56b8b3d36f9424051fbdb0449d738b1f931734a16d12
server-jdk17
10.2 MB
sha256:1bd4920405ef0d139f748031ee0cb2f025fe25494988ece0584c1376b4c128cb
server-jdk8
10.3 MB
sha256:3e24da7879cc5f4d2e4b8e97b3bb5eebf2d1a9284be4dd4f25a258ab86658502