[server][da-vinci][test] Optimize Heartbeat Messages by Excluding VTP Headers #9214
lluwmVeniceCI-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
14s
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
32 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
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L36
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveIntField has a memoryAllocatedPerInstance (13.69124) which is too far from the predictedUsage (16); delta: 0.144; maxAllowedDelta: 0.073. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L36
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveIntField has a memoryAllocatedPerInstance (13.69124) which is too far from the predictedUsage (16); delta: 0.144; maxAllowedDelta: 0.073. 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#L33
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveByteField has a memoryAllocatedPerInstance (7.6972) which is too far from the predictedUsage (16); delta: 0.519; maxAllowedDelta: 0.130. 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#L33
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveByteField has a memoryAllocatedPerInstance (7.6972) which is too far from the predictedUsage (16); delta: 0.519; maxAllowedDelta: 0.130. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L35
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveShortField has a memoryAllocatedPerInstance (12.17308) which is too far from the predictedUsage (16); delta: 0.239; maxAllowedDelta: 0.082. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L35
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveShortField has a memoryAllocatedPerInstance (12.17308) which is too far from the predictedUsage (16); delta: 0.239; maxAllowedDelta: 0.082. No more attempts left.
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
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:2742)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.UnfinishedStubbingException:
Unfinished stubbing detected here:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testReportIfCatchUpVersionTopicOffset$185(StoreIngestionTaskTest.java:6200)
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
|
|
|
|
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
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:2742)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.UnfinishedStubbingException:
Unfinished stubbing detected here:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testReportIfCatchUpVersionTopicOffset$185(StoreIngestionTaskTest.java:6200)
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
|
|
|
|
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L493
java.lang.AssertionError: expected [true] but found [false]
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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:2742)
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L497
com.linkedin.venice.exceptions.VeniceException: Subscribe to new topic:_6d5ab8f3c0_b39a3904_v1 is not successful, error: java.util.concurrent.ExecutionException: java.lang.IllegalThreadStateException
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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:2742)
|
|
VeniceChangelogConsumerImplTest.testConsumeAfterImage:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java#L497
com.linkedin.venice.exceptions.VeniceException: Subscribe to new topic:_6d5ab8f3c0_b39a3904_v1 is not successful, error: java.util.concurrent.ExecutionException: java.lang.IllegalThreadStateException
|
|
RetriableAvroGenericStoreClientTest.testGetWithTriggeringLongTailRetryAndRetryFails[4](MULTI_GET_STREAMING):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientTest.java#L772
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientTest.testGetWithTriggeringLongTailRetryAndRetryFails[2](MULTI_GET):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientTest.java#L774
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientTest.testGetWithTriggeringLongTailRetryAndRetryFails[4](MULTI_GET_STREAMING):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientTest.java#L772
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientTest.testGetWithTriggeringLongTailRetryAndRetryFails[2](MULTI_GET):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientTest.java#L774
java.lang.AssertionError: expected [true] but found [false]
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
921 KB |
sha256:2b27d50ff85b772ad682419dd9a71f4fd59d2bf9023c8f59868e5a19b2fc2f79
|
|
|
clients-jdk11
|
2.97 MB |
sha256:692eee1ed0a538d205ea28c47d6100dfe08a51132105bda5daddff1bde5f8bab
|
|
|
clients-jdk17
|
3 MB |
sha256:87d79c04da2f1826b3425f6944bd4533aeb1c72302b055aa7e2024342857d40b
|
|
|
clients-jdk8
|
2.91 MB |
sha256:75266b6983bcbec22b815ee91095c87df8102ca216b43d1de88f324b0707a65d
|
|
|
controller-jdk11
|
1.97 MB |
sha256:eb14b1b2b74330b5d060a5f644fde92a7c9c4a637db9957b2f9bfad0d2c3dfcb
|
|
|
controller-jdk17
|
1.96 MB |
sha256:64b8f40b6877fd97055df72bf9809e47703fe1769afdee30d60110ccb83daff2
|
|
|
controller-jdk8
|
1.95 MB |
sha256:38b54e4ffd452f94f4558831c03ed075af653c974cc9b0cb1d7afed9e4f8fd0a
|
|
|
integrations-jdk11
|
562 KB |
sha256:02d08908ce10de909b13bcc654944480c737db4a10dadb21c70f3e5bedeb0aac
|
|
|
integrations-jdk17
|
568 KB |
sha256:95d35d3e20b6ecd3e083e625e8dd4df2258d8dbf9669ccf9d7d4bdab36b7593f
|
|
|
integrations-jdk8
|
552 KB |
sha256:c336ad4d177517540f3750f6a2fcf34c18d55c2a324cfde5049f9263409143ea
|
|
|
internal-jdk11
|
4.09 MB |
sha256:ce4d8f3ebd84aeda5b29623f08d5c6e858e69406e13796d56ec8dcbf5bbff7da
|
|
|
internal-jdk17
|
4.11 MB |
sha256:87c6931c2b53c478c3d986513690fbc648c06f0d0173d9cbeb40feaf3e6e0818
|
|
|
internal-jdk8
|
4.08 MB |
sha256:ae7579b38a133d877c2644cf6799fddcab573cd661f63221924112d76911d217
|
|
|
router-jdk11
|
769 KB |
sha256:149dedb2cf6cc85380bb0978617c4434bc36d061718509406522b3f573e3eae8
|
|
|
router-jdk17
|
774 KB |
sha256:85487036c3f0352a435eeea85a9d03ccfc63b3deb02ea25df7612e277fba03c6
|
|
|
router-jdk8
|
761 KB |
sha256:636df460697581b9d44698410e05da3a435a21dab6dcd081f50f06dc38dfb71f
|
|
|
server-jdk11
|
10.2 MB |
sha256:39ba6e2b8bf24569e2c6bbc23df0eb759cf0ca24eaa266ae93eae03648829955
|
|
|
server-jdk17
|
10.3 MB |
sha256:43aca9546413041863ee57d86c19936479a204636eaa4c2e59c659ceb5f1930c
|
|
|
server-jdk8
|
10.3 MB |
sha256:6b2635fcae1e8636810fdcc13e69e4d4bb631d9e5d52af8ccd50d4a57c122550
|
|