[client][da-vinci-client] Add seek to tails API in Seeking DVC client #9289
majisourav99VeniceCI-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
11s
StaticAnalysisAndUnitTestsFailureAlert
3s
Annotations
29 errors
|
Internal / UT & CodeCov (8)
Process completed with exit code 1.
|
|
Internal / UT & CodeCov (8)
Connection reset
|
|
TestVeniceParentHelixAdminWithAcl.cleanupTestCase:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L56
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'stop' is a *void method* and it *cannot* be stubbed with a *return value*!
Voids are usually stubbed with Throwables:
doThrow(exception).when(mock).someVoidMethod();
If you need to set the void method to do nothing you can use:
doNothing().when(mock).someVoidMethod();
For more information, check out the javadocs for Mockito.doNothing().
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. The method you are trying to stub is *overloaded*. Make sure you are calling the right overloaded version.
2. Somewhere in your test you are stubbing *final methods*. Sorry, Mockito does not verify/stub final methods.
3. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
4. Mocking methods declared on non-public parent classes is not supported.
|
|
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L143
org.mockito.exceptions.misusing.WrongTypeOfReturnValue:
Optional cannot be returned by getClustersLeaderOf()
getClustersLeaderOf() should return List
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. This exception *might* occur in wrongly written multi-threaded tests.
Please refer to Mockito FAQ on limitations of concurrency testing.
2. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
|
|
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.cleanupTestCase:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L56
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'stop' is a *void method* and it *cannot* be stubbed with a *return value*!
Voids are usually stubbed with Throwables:
doThrow(exception).when(mock).someVoidMethod();
If you need to set the void method to do nothing you can use:
doNothing().when(mock).someVoidMethod();
For more information, check out the javadocs for Mockito.doNothing().
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. The method you are trying to stub is *overloaded*. Make sure you are calling the right overloaded version.
2. Somewhere in your test you are stubbing *final methods*. Sorry, Mockito does not verify/stub final methods.
3. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
4. Mocking methods declared on non-public parent classes is not supported.
|
|
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L143
org.mockito.exceptions.misusing.WrongTypeOfReturnValue:
Optional cannot be returned by getClustersLeaderOf()
getClustersLeaderOf() should return List
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. This exception *might* occur in wrongly written multi-threaded tests.
Please refer to Mockito FAQ on limitations of concurrency testing.
2. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
|
|
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#L34
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveCharField has a memoryAllocatedPerInstance (13.7288) which is too far from the predictedUsage (16); delta: 0.142; maxAllowedDelta: 0.073. 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 (13.7288) which is too far from the predictedUsage (16); delta: 0.142; maxAllowedDelta: 0.073. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L32
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveBooleanField has a memoryAllocatedPerInstance (17.0896) which is too far from the predictedUsage (16); delta: 0.068; maxAllowedDelta: 0.059. No more attempts left.
|
|
ClassSizeEstimatorTest.testClassOverhead[1](EMPIRICAL_MEASUREMENT):
internal/venice-common/src/test/java/com/linkedin/venice/memory/ClassSizeEstimatorTest.java#L32
java.lang.AssertionError: Class ClassWithOnePublicPrimitiveBooleanField has a memoryAllocatedPerInstance (17.0896) which is too far from the predictedUsage (16); delta: 0.068; maxAllowedDelta: 0.059. No more attempts left.
|
|
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]
|
|
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.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:2745)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2745)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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) 0x32, (byte) 0x35, (byte) 0x33, (byte) 0x34, (byte) 0x66, (byte) 0x64, (byte) 0x37, (byte) 0x35, (byte) 0x61, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x36, (byte) 0x63, (byte) 0x63, (byte) 0x66, (byte) 0x61, (byte) 0x61, (byte) 0x31],
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)
|
|
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:2745)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2745)
|
|
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:2745)
|
|
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:2745)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2745)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testResetPartition[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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) 0x32, (byte) 0x35, (byte) 0x33, (byte) 0x34, (byte) 0x66, (byte) 0x64, (byte) 0x37, (byte) 0x35, (byte) 0x61, (byte) 0x38, (byte) 0x5F, (byte) 0x64, (byte) 0x36, (byte) 0x63, (byte) 0x63, (byte) 0x66, (byte) 0x61, (byte) 0x61, (byte) 0x31],
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)
|
|
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:2745)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2745)
|
|
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:2745)
|
|
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
However, there were exactly 18 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
5.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2113)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.052218d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:781)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1726)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.270296d,
1764038055670L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1417)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1422)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.080051d,
1764038055675L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1417)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1422)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2737)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2113)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.051757d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:781)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1726)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.075811d,
1764038055687L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1417)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1422)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2737)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2737)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2113)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.035366d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:781)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1726)
|
|
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
Wanted but not invoked:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:507)
However, there were exactly 18 interactions with this mock:
hostLevelIngestionStats.recordProcessConsumerActionLatency(
5.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2113)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.052218d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:781)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1726)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.270296d,
1764038055670L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1417)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1422)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.080051d,
1764038055675L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1417)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1422)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2737)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2113)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.051757d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:781)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1726)
hostLevelIngestionStats.recordConsumerRecordsQueuePutLatency(
0.075811d,
1764038055687L
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1417)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.produceToStoreBufferServiceOrKafka(StoreIngestionTask.java:1422)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2737)
hostLevelIngestionStats.recordTotalRecordsConsumed();
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2737)
hostLevelIngestionStats.recordProcessConsumerActionLatency(
0.0d
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2113)
hostLevelIngestionStats.recordCheckLongRunningTasksLatency(
0.035366d
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.checkLongRunningTaskState(LeaderFollowerStoreIngestionTask.java:781)
hostLevelIngestionStats.recordStorageQuotaUsed(
NaNd
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.recordQuotaMetrics(StoreIngestionTask.java:1726)
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[14](MULTI_GET_STREAMING, true, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
RetriableAvroGenericStoreClientRetryBudgetTest.testGetWithTriggeringLongTailRetryAndRetryWins[14](MULTI_GET_STREAMING, true, false):
clients/venice-client/src/test/java/com/linkedin/venice/fastclient/RetriableAvroGenericStoreClientRetryBudgetTest.java#L1
java.lang.AssertionError: expected [true] but found [false]
|
|
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
922 KB |
sha256:00358900e95afd46abc57ae62c64174a01e248b0930e788d535df45168eb3a3f
|
|
|
clients-jdk11
|
2.96 MB |
sha256:8df659e2adf3a15bd5f1c9287d4b6ca931824b370832be685e4f193a9422e878
|
|
|
clients-jdk17
|
3 MB |
sha256:561228c9f1a2dd07bc0e1fce8b493f951e9b0bfa86933496298ca9d7a16dc08c
|
|
|
clients-jdk8
|
2.92 MB |
sha256:19eb89c633075aee2d197f83e7db6cbbed2a6ff50b58b0d9aaade6e754462a96
|
|
|
controller-jdk11
|
2.01 MB |
sha256:1928389c9ce7ca013c27a117428fc32b9c4572afee497a03853e468ebd114d12
|
|
|
controller-jdk17
|
1.97 MB |
sha256:8cbf93b4e5430b22afdec03928e2b7187d10906681707667fc000eaed8c8a4a0
|
|
|
controller-jdk8
|
1.99 MB |
sha256:d03789cd981fa981193a542157514eb50dc374834f5c3999c5dac71ffcc65902
|
|
|
integrations-jdk11
|
564 KB |
sha256:4f495b86f7cefb20fe591b689462e3ce561974fa941e59c0e52695e3bf60dd71
|
|
|
integrations-jdk17
|
571 KB |
sha256:d927de802087abc25cb30384684beeae8a70d3e09bc63f355647a311d79b32f7
|
|
|
integrations-jdk8
|
553 KB |
sha256:aacaa5b37dc4c41f0e3305e840ce07930636040cc5d3e2e9d7e657307476fbbc
|
|
|
internal-jdk11
|
4.06 MB |
sha256:dbe35b8a0e42bb41ed87a2ec8c0fe55be73b9219e166b927ac1094b308105b7a
|
|
|
internal-jdk17
|
4.08 MB |
sha256:dee8343aa3eca0ca2980e79e5ed33c49e65f082af7e32813446f9d00bf275396
|
|
|
internal-jdk8
|
280 Bytes |
sha256:c5c080041693a3413f060466bf2c1f436ce5661dda6b2bfd75839aa153e1f283
|
|
|
router-jdk11
|
771 KB |
sha256:39e5152b6e82853c5af0bcc563585164a4acd3c707df904b62333cf6c7274336
|
|
|
router-jdk17
|
773 KB |
sha256:23ee8621813965d725f5793faa9c3ad1bbd3d0a185c83568b04b592718ce21eb
|
|
|
router-jdk8
|
760 KB |
sha256:a2d94445f4dd9dde34acf11a574372f7afb16cb3493149426882d87dc24f75c9
|
|
|
server-jdk11
|
10.5 MB |
sha256:8fb22652607f05ee81e2edadebe6405bc0e09e16405f617355f8ec690b062c0b
|
|
|
server-jdk17
|
10.3 MB |
sha256:656c368e3f0b6dcb218f76607bcf0706159ac5537cada447b317fdacfce6bc57
|
|
|
server-jdk8
|
10.2 MB |
sha256:a678ca671e7a6ce701575d1611f31336e35fe395ea0342202f7e427dce2f62d4
|
|