Skip to content

[server][dvc] Preserve PCS during non-Helix UNSUBSCRIBE to maintain quota accuracy #9279

[server][dvc] Preserve PCS during non-Helix UNSUBSCRIBE to maintain quota accuracy

[server][dvc] Preserve PCS during non-Helix UNSUBSCRIBE to maintain quota accuracy #9279

Triggered via pull request November 24, 2025 19:35
Status Success
Total duration 13m 1s
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
14s
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
0s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

16 errors
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
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#L29
java.lang.AssertionError: Class SubclassOfObjectWithNoFields has a memoryAllocatedPerInstance (32.19616) which is too far from the predictedUsage (16); delta: 1.012; maxAllowedDelta: 0.031. 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#L29
java.lang.AssertionError: Class SubclassOfObjectWithNoFields has a memoryAllocatedPerInstance (32.19616) which is too far from the predictedUsage (16); delta: 1.012; maxAllowedDelta: 0.031. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L26
java.lang.AssertionError: Class Object has a memoryAllocatedPerInstance (5.1894) which is too far from the predictedUsage (16); delta: 0.676; maxAllowedDelta: 0.193. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L26
java.lang.AssertionError: Class Object has a memoryAllocatedPerInstance (5.1894) which is too far from the predictedUsage (16); delta: 0.676; maxAllowedDelta: 0.193. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L34
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveCharField has a memoryAllocatedPerInstance (10.97432) which is too far from the predictedUsage (16); delta: 0.314; maxAllowedDelta: 0.091. No more attempts left.
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT): internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L34
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveCharField has a memoryAllocatedPerInstance (10.97432) which is too far from the predictedUsage (16); delta: 0.314; maxAllowedDelta: 0.091. No more attempts left.
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:2740)
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:2740)
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.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1476) But was 2 times: -> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.addMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:611) -> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.addMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:611)
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.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1476) But was 2 times: -> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.addMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:611) -> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.addMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:611)

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis
922 KB
sha256:1c14dee255bddb1b9d2943b55bf79ad297a9c4c358b14b9ed9a3acd8f7be2e84
clients-jdk11
2.92 MB
sha256:32e0df4d3cc077e84f4ee2c3c2375737bd1c6bcd01e59c6678ab759959020986
clients-jdk17
2.98 MB
sha256:a85530c81e385f5d58b214cedb8451e91f2b3e4e0d09dacc573364e3247ee88c
clients-jdk8
2.89 MB
sha256:07622029486ae90ee4c03d09c1e513a190ec3b792efbd1c3143c3ee51cbe7f93
controller-jdk11
1.98 MB
sha256:fe7c3f4314d981ec1570b170001aa23d0425b42a6e747594f052af0238474366
controller-jdk17
1.96 MB
sha256:b1856db9246998b8402bd754b7656c6e175571cf0c7f21bdf3d8d3b850f64d96
controller-jdk8
1.98 MB
sha256:ac8d6db7ea09b17125f927a2e6493dd2cabb7a9f20598aa07b3cc2a8556d2bed
integrations-jdk11
534 KB
sha256:a533e06da857ca43fa8e6f36e9dd17d5f16b06222d528c5afbacf3e64131fbcf
integrations-jdk17
540 KB
sha256:6372d1c77e6ab3a364ee949c37b7b638c38c5dc9a810ef57193a4c8d837dab1d
integrations-jdk8
524 KB
sha256:d54d9f840bb0162f3b53b9d0839ef1bf507345838f2b78fac64923047d3d71ec
internal-jdk11
4.04 MB
sha256:9514395d6a4207b1d4582351b334f51002df34b16a6068ad35c6eac0016368a2
internal-jdk17
4.05 MB
sha256:3e04c336aafdcb90ff77c8e06d3bdcf3e057dbe28dbc36f454e8a83023e5d336
internal-jdk8
4.02 MB
sha256:45b98d6788df3077c3a6825915273d2723003719dabca1293ff56997811f0698
router-jdk11
762 KB
sha256:0d5460d9b8a2e37f7d6efca37918bb8759c2df67bbb7a0ea73adec925d370a82
router-jdk17
766 KB
sha256:20fe0afacadbd5bc091b17de6904dfc2fb2e5b49b087085d00e051593ef62ce0
router-jdk8
753 KB
sha256:a0df89456202e8148cea26ecab9dd63f93363799e65563a4848fe1d08e73463a
server-jdk11
25 MB
sha256:69c6d214e043bd96efc22076e4a94e816ea094c2bcde0b532ffb90f18c04190f
server-jdk17
10.3 MB
sha256:e77d47522c2433a254588a8670337907a519e66546ecb83355c4427e65c57e99
server-jdk8
10.4 MB
sha256:8687a046dfe0c47cba139363956488701a3dcacb37bb2fbc7e7613bba515d268