[changelog][cdc] Add client side handling of new A/A version swap messages #9301
xunyin8VeniceCI-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
10s
StaticAnalysisAndUnitTestsFailureAlert
0s
Annotations
18 errors
|
TestVeniceParentHelixAdminWithAcl.cleanupTestCase:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L56
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.cleanupTestCase:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L56
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 (43.92556) which is too far from the predictedUsage (40); delta: 0.098; maxAllowedDelta: 0.023. 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 (43.92556) which is too far from the predictedUsage (40); delta: 0.098; maxAllowedDelta: 0.023. 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 (54.5542) which is too far from the predictedUsage (40); delta: 0.364; maxAllowedDelta: 0.018. 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 (54.5542) which is too far from the predictedUsage (40); delta: 0.364; maxAllowedDelta: 0.018. No more attempts left.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testResetPartition[1](AA_OFF):
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) 0x36, (byte) 0x63, (byte) 0x31, (byte) 0x63, (byte) 0x66, (byte) 0x65, (byte) 0x64, (byte) 0x31, (byte) 0x34, (byte) 0x30, (byte) 0x5F, (byte) 0x63, (byte) 0x38, (byte) 0x61, (byte) 0x63, (byte) 0x35, (byte) 0x63, (byte) 0x61, (byte) 0x37],
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)
|
|
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)
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testResetPartition[1](AA_OFF):
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) 0x36, (byte) 0x63, (byte) 0x31, (byte) 0x63, (byte) 0x66, (byte) 0x65, (byte) 0x64, (byte) 0x31, (byte) 0x34, (byte) 0x30, (byte) 0x5F, (byte) 0x63, (byte) 0x38, (byte) 0x61, (byte) 0x63, (byte) 0x35, (byte) 0x63, (byte) 0x61, (byte) 0x37],
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)
|
|
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)
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L149
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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
|
|
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)
|
|
NativeMetadataRepositoryTest.testNativeMetadataRepositoryStats:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/repository/NativeMetadataRepositoryTest.java#L149
java.lang.AssertionError: expected [2000.0] but found [1000.0]
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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
|
|
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)
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
923 KB |
sha256:ef44f58909f1e946b28783834005f926835ec5fdcc700aec5d3ecbc2621d499a
|
|
|
clients-jdk11
|
3 MB |
sha256:d49dad068c4f6711821fc247d272841aa5ef11ff3785d2f1c7c3eebc4493ce92
|
|
|
clients-jdk17
|
3.04 MB |
sha256:38f6b2e031087c7c3392f01e6fc6b85c36dbc11b9cc3e264163cd0ad68f9a2a4
|
|
|
clients-jdk8
|
2.96 MB |
sha256:f8c56fa62620cff48fa5667dc0aaee84b3ab46e784fdd8ad5992df50cbf8379d
|
|
|
controller-jdk11
|
2 MB |
sha256:2b036f71dd7d0010f20bedda5e08ceb6317cdecbe67eefdd1861da54102dbd64
|
|
|
controller-jdk17
|
2 MB |
sha256:f009fdca9c9eb283e34b86bed54563bbee2979fd3e68fd2b10dc82ef5e8859e7
|
|
|
controller-jdk8
|
1.99 MB |
sha256:1a359cce50db578eae3cb2aefcab358d9e74661ee216f0a059034537c7df4f35
|
|
|
integrations-jdk11
|
597 KB |
sha256:60ac07b1335398b46ec6c29dff8dacedb90796f1e21289d69d4e72e80cb8c030
|
|
|
integrations-jdk17
|
604 KB |
sha256:fec428d28d0ab1d182ca6ce252ffc80c567192f0620b980abfe732ef963a765e
|
|
|
integrations-jdk8
|
583 KB |
sha256:d2727f9aab6c03f9e35697bc3526cf1ac382a5a68ca0f5eb9014d4bdd6bbec5a
|
|
|
internal-jdk11
|
4.12 MB |
sha256:abe73ca83bdb9f19b64b2bba28ccb44e76b20e4414f71535f52dbc52ac6ffc0d
|
|
|
internal-jdk17
|
4.13 MB |
sha256:d6c49fd2f5246ea13949e3adf4e6b342039717e8a778da3bb099ed6e4a41beb4
|
|
|
internal-jdk8
|
4.1 MB |
sha256:97640cef052cc93474f05b4892e9598fd7c0ffc40a4037ac7a9179fd1da8c81d
|
|
|
router-jdk11
|
778 KB |
sha256:b83ecef2a1720bbd5b3eaac4810ee60779692edc46b963e1e2e4173c817d8252
|
|
|
router-jdk17
|
783 KB |
sha256:89ce40c1a35e78f06d466c1f267523dd917262f7c22f66e43e488dd0639acf18
|
|
|
router-jdk8
|
771 KB |
sha256:900e658ab7a3f72d7c0d31dda73b8eb562ed9b3526fc1d7d1218dc7993666501
|
|
|
server-jdk11
|
10.5 MB |
sha256:d3853f7760807756066aa481cc7857111cb9610c0a3a2980c1218702806bbe37
|
|
|
server-jdk17
|
10.4 MB |
sha256:88f900edaa0ad9fe9ceeeaedc8c5620db5791684899e853ebc237daae3a68602
|
|
|
server-jdk8
|
10.2 MB |
sha256:21b7ecac7962f1791b5a7c7517bcb19dfd2aa68e2b5bda933ee16157eef4459f
|
|