[server] Introduce record level delay with heartbeat delay #10135
misyelVeniceCI-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
2s
Annotations
42 errors
|
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L149
java.lang.AssertionError: ACLs were not properly cleared on deleteAclForStore. Actual: {Resource:test-store-authorizer, [{Principal:user:user2, Method:Read, Permission:ALLOW}{Principal:group:group2, Method:Read, Permission:ALLOW}{Principal:service:app2, Method:Read, Permission:ALLOW}{Principal:user:user2, Method:Write, Permission:ALLOW}{Principal:group:group2, Method:Write, Permission:ALLOW}{Principal:service:app2, Method:Write, Permission:ALLOW}{Principal:user:denyuser1, Method:Read, Permission:DENY}]}, Expected: {Resource:test-store-authorizer, []} expected [true] but found [false]
|
|
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl:
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L149
java.lang.AssertionError: ACLs were not properly cleared on deleteAclForStore. Actual: {Resource:test-store-authorizer, [{Principal:user:user2, Method:Read, Permission:ALLOW}{Principal:group:group2, Method:Read, Permission:ALLOW}{Principal:service:app2, Method:Read, Permission:ALLOW}{Principal:user:user2, Method:Write, Permission:ALLOW}{Principal:group:group2, Method:Write, Permission:ALLOW}{Principal:service:app2, Method:Write, Permission:ALLOW}{Principal:user:denyuser1, Method:Read, Permission:DENY}]}, Expected: {Resource:test-store-authorizer, []} expected [true] but found [false]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2420121200; memoryAllocatedAfterInstantiations: 2412916848; memoryAllocatedByInstantiations: -7204352; 3 attempts left.
|
|
TopicMetadataFetcherTest.testGetEarliestPositionCachedNonBlockingScenarios:
internal/venice-common/src/test/java/com/linkedin/venice/pubsub/manager/TopicMetadataFetcherTest.java#L709
java.lang.AssertionError: expected [1] but found [0]
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2420121200; memoryAllocatedAfterInstantiations: 2412916848; memoryAllocatedByInstantiations: -7204352; 3 attempts left.
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
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:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2798)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
Server / UT & CodeCov (17)
Process completed with exit code 1.
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testVeniceMessagesProcessingWithTemporarilyNotAvailableSchemaId[0](AA_ON):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
readOnlySchemaRepository.hasValueSchema(
"TestTopic_7592f332b2_78204a0a",
2
);
Wanted *at least* 3 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testVeniceMessagesProcessingWithTemporarilyNotAvailableSchemaId$39(StoreIngestionTaskTest.java:1770)
But was 0 times.
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testResubscribeAfterRoleChange:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
abstractStorageEngine.put(2, <any>, <any>);
-> at com.linkedin.davinci.store.AbstractStorageEngine.put(AbstractStorageEngine.java:478)
However, there were exactly 3 interactions with this mock:
abstractStorageEngine.getStoreVersionState();
-> at com.linkedin.davinci.store.DelegatingStorageEngine.getStoreVersionState(DelegatingStorageEngine.java:274)
abstractStorageEngine.getPartitionOrThrow(1);
-> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294)
abstractStorageEngine.getPartitionOrThrow(2);
-> at com.linkedin.davinci.store.DelegatingStorageEngine.getPartitionOrThrow(DelegatingStorageEngine.java:294)
|
|
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:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2798)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
KafkaConsumerServiceDelegatorTest.testKafkaConsumerServiceResubscriptionConcurrency:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java#L364
java.lang.AssertionError: expected [true] but found [false]
|
|
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.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1938)
But was 2 times:
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.internalAddMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:741)
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl$DaVinciRecordTransformerChangelogConsumer.internalAddMessageToBuffer(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:741)
|
|
Server / UT & CodeCov (8)
Process completed with exit code 1.
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
KafkaConsumerServiceDelegatorTest.testKafkaConsumerServiceResubscriptionConcurrency:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java#L364
java.lang.AssertionError: expected [true] but found [false]
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.methodSetUp:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.UnfinishedVerificationException:
Missing method call for verify(mock) here:
-> at com.linkedin.davinci.stats.AggKafkaConsumerServiceStats.recordTotalUpdateCurrentAssignmentLatency(AggKafkaConsumerServiceStats.java:68)
Example of correct verification:
verify(mock).doSomething()
Also, this error might show up because you verify either of: final/private/equals()/hashCode() methods.
Those methods *cannot* be stubbed/verified.
Mocking methods declared on non-public parent classes is not supported.
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testVeniceMessagesProcessingWithSortedInputWithBlobMode[2](false, true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'put' 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.
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1010
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
heartbeatMonitoringService.recordLeaderHeartbeat(
"foo",
1,
100,
"c1",
123L,
false
);
-> at com.linkedin.davinci.stats.ingestion.heartbeat.HeartbeatMonitoringService.recordLeaderHeartbeat(HeartbeatMonitoringService.java:331)
Actual invocations have different arguments:
heartbeatMonitoringService.recordLeaderHeartbeat(
null,
"foo",
1,
"c1",
123L,
false
);
-> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.recordHeartbeatReceived(LeaderFollowerStoreIngestionTask.java:2331)
|
|
KafkaConsumerServiceDelegatorTest.testKafkaConsumerServiceResubscriptionConcurrency:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java#L364
java.lang.AssertionError: expected [true] but found [false]
|
|
Server / UT & CodeCov (11)
Process completed with exit code 1.
|
|
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
951 KB |
sha256:98f28c0ef218a59039223d4ff0632f60c10e021b17ba96f7479286034d081c60
|
|
|
clients-jdk11
|
3.3 MB |
sha256:39e865a66f4f0d4b72f33a063d480d3e3c3a6c2c4ec431337103dd2f643b23f8
|
|
|
clients-jdk17
|
3.3 MB |
sha256:8998a0b7733da2be00b065502d7c718b5a9a0f471e0cf0b5b0dd2c2c73b8e05f
|
|
|
clients-jdk8
|
3.27 MB |
sha256:4e977fac7f7e27d302e95af2291bd7f0fcb8c8f4b1bf3cff6c7838375001c6f7
|
|
|
controller-jdk11
|
1.99 MB |
sha256:9baf7f1115c5efcba105ee5527b4007e82f2936238a4ae6e4dadea32afbc64ed
|
|
|
controller-jdk17
|
2 MB |
sha256:d409571265689a8b9d8e58c926b5baad65145534e546b748f9b4454552577a35
|
|
|
controller-jdk8
|
1.98 MB |
sha256:2f644f0ad2dba1daa6df88797d2c84ca160afe9c1a18fa6bfcd3ccc71407f7d8
|
|
|
integrations-jdk11
|
637 KB |
sha256:0888b6049476d68753029654a74e46ef1f8f5dd5e351f2c484a19f637cde44cb
|
|
|
integrations-jdk17
|
644 KB |
sha256:a24d0cc6cea62febc2fd9efbbd03199836a5ab1484eac6ebea01b0da51409736
|
|
|
integrations-jdk8
|
622 KB |
sha256:1b545d3c8e6218adb4ba807693f03ce711d49719595e91c888a877feeeee00a0
|
|
|
internal-jdk11
|
4.33 MB |
sha256:3f111e6c4c2bf77a2d4fc149bdf9325e9d89307b06acf6e6e667fa4412e7ac43
|
|
|
internal-jdk17
|
4.34 MB |
sha256:fddc8738f52d5efcfcffdd26b6bfa682856dbf1fca0d2ab213efe3132e76895f
|
|
|
internal-jdk8
|
4.32 MB |
sha256:41a7819ec4def74881c910c731e7d6afb72d80442cb761149a6660cbe2ead612
|
|
|
router-jdk11
|
777 KB |
sha256:b531b4d02d462454dccc2b8e9fc851eb173ae17f3b05fce296117b8abcae407c
|
|
|
router-jdk17
|
776 KB |
sha256:b12e2098e192968fd80ab0b15f55c2b1b45f4dcacca27aee4ebeeef9967cad08
|
|
|
router-jdk8
|
766 KB |
sha256:16e4c3d17f627ff2300effd734137c40a4ef4fba2b7f89f5c3ed087d21864897
|
|
|
server-jdk11
|
18.7 MB |
sha256:eeace460b0bcbda4ad171c3526fddee34d1ffde49aa5822e4a2d28562b57123f
|
|
|
server-jdk17
|
9.01 MB |
sha256:6f6496262ecf32f1da77372e469bd2db672947deb867833a2adb93de39d5b382
|
|
|
server-jdk8
|
18.9 MB |
sha256:c9d7467d69c5deb4c54af6161f1e0fa6a8ffac18536c29b5951b6ffc0123f2b0
|
|