[server] Introduce record level delay with heartbeat delay #10110
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
10s
StaticAnalysisAndUnitTestsFailureAlert
3s
Annotations
36 errors
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2418647080; memoryAllocatedAfterInstantiations: 2410394152; memoryAllocatedByInstantiations: -8252928; 3 attempts left.
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2418647080; memoryAllocatedAfterInstantiations: 2410394152; memoryAllocatedByInstantiations: -8252928; 3 attempts left.
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
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]
|
|
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:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2794)
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
LeaderFollowerStoreIngestionTaskTest.testHeartbeatRecord:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTaskTest.java#L1
java.lang.NullPointerException: Cannot invoke "String.hashCode()" because "storeName" is null
|
|
Server / UT & CodeCov (17)
Process completed with exit code 1.
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Server / UT & CodeCov (11)
Process completed with exit code 1.
|
|
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:2794)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testPartitionExceptionIsolation[1](AA_OFF):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked:
logNotifier.completed(
"TestTopic_9402e085b8_c933f981_v1",
2,
<Capturing argument>,
"STANDBY"
);
-> at com.linkedin.davinci.notifier.LogNotifier.completed(LogNotifier.java:27)
However, there was exactly 1 interaction with this mock:
logNotifier.started(
"TestTopic_9402e085b8_c933f981_v1",
1
);
-> at com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher.lambda$reportStarted$1(IngestionNotificationDispatcher.java:117)
|
|
SITWithPWiseAndBufferAfterLeaderTest.methodCleanUp:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'recordTotalAvgPartitionsPerConsumer' 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.
|
|
SITWithPWiseAndBufferAfterLeaderTest.methodSetUp:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'recordTotalPollRequestLatency' 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.
|
|
|
|
|
|
|
|
|
|
|
|
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 (8)
Process completed with exit code 1.
|
|
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
927 KB |
sha256:4e185636b0384f5e4226a3a8ea6d031b18f95d3c1d4bf9628e88c21b7819d9f1
|
|
|
clients-jdk11
|
3.29 MB |
sha256:06c6438c503b6572a3341ab8ca54ba2c0eda24484af45c55da88b10f0f2e16d6
|
|
|
clients-jdk17
|
3.33 MB |
sha256:51e62def37480325c46d2f4ac6ce9211fa7948cad1ebf2e9b66c44780f36ce4e
|
|
|
clients-jdk8
|
3.25 MB |
sha256:ad2f7994b3b7e76fda0e47653bc985886c1e2899b902269027f834c46f1ff5a5
|
|
|
controller-jdk11
|
2 MB |
sha256:0771b197f408df5cb91115d550c241b2be72d39a2e3fbd65c5eeb2a5206c8ef5
|
|
|
controller-jdk17
|
1.99 MB |
sha256:d744ce961f16d9f74a09ab2af4580260693d14b4ca352c8b92e8709a40989f2d
|
|
|
controller-jdk8
|
1.98 MB |
sha256:97c31f80e44b921add8500a90f9821ffbe4f62063c1adf79d0558de4fdd1df23
|
|
|
integrations-jdk11
|
627 KB |
sha256:d29dfcb6f86e184796ff00f1950303486e7a36e63592c40870467c15e04885d0
|
|
|
integrations-jdk17
|
640 KB |
sha256:ccd914bada3cb528fb09a9daa8ae5435cbfb572e531f81d9267ee0d281eaa636
|
|
|
integrations-jdk8
|
619 KB |
sha256:5c6c24bca98da632cb99e9cf0589bf94d5b111a2316be222bcdb1d695abf7c45
|
|
|
internal-jdk11
|
4.34 MB |
sha256:4364947147a456b9d91d36e6916333cd88db923742166ff2a0e61b849da6b3ec
|
|
|
internal-jdk17
|
4.35 MB |
sha256:f5e6ee2bf2ae81551bcb1574360c10327257c2d644ca3f3417f3dfe4211ee360
|
|
|
internal-jdk8
|
4.32 MB |
sha256:cf293140e06ad523fbd41ab964fe73a4093e8add3d2ad37e6ba90a660bc8710b
|
|
|
router-jdk11
|
779 KB |
sha256:482fe5407f2d4efbf0ab38c1de9d13d0a6de10d49a2c9027ec3e421c947afb09
|
|
|
router-jdk17
|
787 KB |
sha256:d4d5ab8dc3a76f0395a2e9bacb95d045a6a6dd60f69187c71d0dcc9d21e0c8dc
|
|
|
router-jdk8
|
769 KB |
sha256:dd74607985a3da339fb0d0ec852bb48b55ce556d856a01d992dfde01736a2bff
|
|
|
server-jdk11
|
8.84 MB |
sha256:dfe61eda053713c4407bfa71ced81546322378afa085ab633ba3f3f425f4cc5d
|
|
|
server-jdk17
|
8.87 MB |
sha256:465dcf875ef23d6cc1c8f44c0582e9ef51e48ab81a43638f77141c4b38a84c16
|
|
|
server-jdk8
|
19.3 MB |
sha256:f806d5cacbb60f33c00c9eadc3ecba776e5677954865b0d0dcb1374760b6d23e
|
|