Skip to content

[server] Add a heartbeat lag based replica auto resubscribe feature #9302

[server] Add a heartbeat lag based replica auto resubscribe feature

[server] Add a heartbeat lag based replica auto resubscribe feature #9302

Triggered via pull request November 26, 2025 08:58
Status Success
Total duration 12m 7s
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
11s
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
0s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

10 errors
InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (72.42208) which is too far from the predictedUsage (40); delta: 0.811; maxAllowedDelta: 0.014. 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 (72.42208) which is too far from the predictedUsage (40); delta: 0.811; maxAllowedDelta: 0.014. 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#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
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true): 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 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:2742) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2742)
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true): 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 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:2742) -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2742)

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis
923 KB
sha256:014385f9979d830971a67d6ee764b25750598e86fe0ca7bbd3a0f7bc71d471ea
clients-jdk11
2.96 MB
sha256:32db1cc9ac52357657ed11c70bf4dd04f5db34e8db0c7344902666319838f4c6
clients-jdk17
2.99 MB
sha256:090239d6bb381538cd8c1461bf5fe2d6ac58a90aaf1a1e694fb2fa5cb1a0582e
clients-jdk8
2.91 MB
sha256:968d33ce292f9b13df6325704fef981b40faec52410389a520a8f0fd62827a1d
controller-jdk11
1.98 MB
sha256:4ea87309ff721c7f5575b34964750a863c47ec7d131eed6483d05cd494908090
controller-jdk17
1.99 MB
sha256:8798c62b1910504a879fcd31803755e740e9ad4ad2cdb7aabdc72e152cc39fcc
controller-jdk8
1.99 MB
sha256:bfdbee89165e8f888d3280ab3315122e6471412504f91149f2e29fd38d24ebd0
integrations-jdk11
556 KB
sha256:ea7d767b2677dc4cece4679d15256a7260f62b73451846a581ad1f9b3d22cb93
integrations-jdk17
561 KB
sha256:357e019944f0e69c72cd53ce95f468573b51a9326977c272d38d4a25b041e1bc
integrations-jdk8
541 KB
sha256:c84bee986b3e1bdabb10a753daad87e8abf2e5a037f2fd5daaa41b4e0e87f40a
internal-jdk11
4.08 MB
sha256:c5fc0b023c6d7bcac9c09919d10875ec625571098924e07d554a0c8a88d4baae
internal-jdk17
4.09 MB
sha256:92253a7c10f682775b137cd1c395f6a68c698aa7a31cc8b3f37f1ce460d1da64
internal-jdk8
4.06 MB
sha256:9d2c5109a7bef2e0153d20228bcbb2ad0717d51a9635b27c78da00ea305d55af
router-jdk11
767 KB
sha256:7730495c1398854d3d367d0f02ffa3096b1ad4c9597db9d004589f45fa6b4ff4
router-jdk17
773 KB
sha256:b95334dde97ade505dc739822c3e3643d18673ddc5be1f841c8fed6c9d36b6ae
router-jdk8
760 KB
sha256:8be5763499557d3c104a5ed09425463166d677c510a6c6d7a679993627f987b4
server-jdk11
10.4 MB
sha256:77c27cf6d4fc0cd5d5eb8b0a3a72f4afb3732be353c658ffe8999d14d69e2ff3
server-jdk17
10.5 MB
sha256:93aeee84e7420ff207fd35364e4329fe0b9e4663911f9565fed1630262268858
server-jdk8
10.1 MB
sha256:add98ed146a3121491bbcf467737c4253b1ffd28c671d17293b1054480cd3509