[controller] Skip the parent VT truncate based on the concurrent push strategy #9306
sofiaz11VeniceCI-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
13s
StaticAnalysisAndUnitTestsFailureAlert
Annotations
12 errors
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2454884088; memoryAllocatedAfterInstantiations: 2450328312; memoryAllocatedByInstantiations: -4555776; 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: 2454884088; memoryAllocatedAfterInstantiations: 2450328312; memoryAllocatedByInstantiations: -4555776; 3 attempts left.
|
|
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)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
java.util.concurrent.ExecutionException: org.mockito.exceptions.misusing.WrongTypeOfReturnValue:
Long cannot be returned by getIsRunning()
getIsRunning() should return AtomicBoolean
***
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.
|
|
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)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
java.util.concurrent.ExecutionException: org.mockito.exceptions.misusing.WrongTypeOfReturnValue:
Long cannot be returned by getIsRunning()
getIsRunning() should return AtomicBoolean
***
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.
|
|
VeniceChangelogConsumerDaVinciRecordTransformerImplTest.testMaxBufferSize:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImplTest.java#L476
Wanted but not invoked:
conditionObject.signal();
-> at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1476)
However, there was exactly 1 interaction with this mock:
conditionObject.await(100L, MILLISECONDS);
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl.poll(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:398)
|
|
VeniceChangelogConsumerDaVinciRecordTransformerImplTest.testMaxBufferSize:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImplTest.java#L476
Wanted but not invoked:
conditionObject.signal();
-> at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.signal(AbstractQueuedSynchronizer.java:1476)
However, there was exactly 1 interaction with this mock:
conditionObject.await(100L, MILLISECONDS);
-> at com.linkedin.davinci.consumer.VeniceChangelogConsumerDaVinciRecordTransformerImpl.poll(VeniceChangelogConsumerDaVinciRecordTransformerImpl.java:398)
|
|
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:2739)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
|
|
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:2739)
|
|
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:2739)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2739)
|
|
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:2739)
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
|
924 KB |
sha256:2d3281c66b11d42b97f518f3a89d6a2f00c082cd15eb52bd6a72e148c5dfc66e
|
|
|
clients-jdk11
|
2.93 MB |
sha256:c4134722094bcd14fbc5d5df7f0c23fea8d2a054f281785806f15d5a4afb3d7b
|
|
|
clients-jdk17
|
2.97 MB |
sha256:19aa4cfb56969d0afe5c2d45fef072b86d4c554440574d7273ec3579e1b76ed4
|
|
|
clients-jdk8
|
2.89 MB |
sha256:6d48f4e1d84d851ec04a968880245a73aa3b8800738a890013ee3ac0c1619469
|
|
|
controller-jdk11
|
2 MB |
sha256:7ab6e7006038abdafd872e9dbd1e2a68e978c64d50fdccdd4f23438f31ab8641
|
|
|
controller-jdk17
|
1.97 MB |
sha256:dc96bdb4e616be93da268c4f7a6ace3a3b183104dd4f1b0222e217b730a2d08e
|
|
|
controller-jdk8
|
1.98 MB |
sha256:7aea583c96ebe6f10d60d08d8014b9d183668fc95900a3223bf4644df5c9a4d1
|
|
|
integrations-jdk11
|
540 KB |
sha256:9d71043394fb6954fa4af748b6e97172d3007c820bed8829ea36734a959abf93
|
|
|
integrations-jdk17
|
545 KB |
sha256:d544b8b9dccff27f65f50f80a6919d9defc3a4f1b848c8c6c6a588dbe8166163
|
|
|
integrations-jdk8
|
525 KB |
sha256:389036d1b566780cf448cf534d8274bc0a2cd4063f12ebd565e60a1e2f6b9417
|
|
|
internal-jdk11
|
4.06 MB |
sha256:134343491606a5c765a40ab0271a7e9e6a64afce684325633004963a71aafac1
|
|
|
internal-jdk17
|
4.07 MB |
sha256:5e399064fc505d59ad60910fcb99716e6e95008ae3132c1c9434cf28fc002c79
|
|
|
internal-jdk8
|
4.05 MB |
sha256:597215b4559c5949015bb1c8bcb509842e8b7ff27e054db7816fb2a7e5dea1aa
|
|
|
router-jdk11
|
763 KB |
sha256:a712dab8e4ee55a6a18e5e06ab21d0049274699c3adc3d1a61d7022f8eb1f9ee
|
|
|
router-jdk17
|
768 KB |
sha256:47eeea42b33b83d7274444bdee581b2bc3541084fe748b657d244372d106116d
|
|
|
router-jdk8
|
753 KB |
sha256:97079a02899b67f2ee71d39758b2c4a8fc8b937a00bf708d336e623dadf04c1d
|
|
|
server-jdk11
|
10.2 MB |
sha256:eb5d4d6df7fd5e045de5324c7ba824079a317c952d3d5454f6a91f570f960c91
|
|
|
server-jdk17
|
10.2 MB |
sha256:0a19f07efaa2d2902e0507be72a70322d94a8161b6020216078a8b577dd0fa41
|
|
|
server-jdk8
|
9.98 MB |
sha256:cb1251756054249712434b6250a1f34f13f597deb30712079a50c8c11fb9341f
|
|