Skip to content
AnalyseStatiqueEtTestsUnitaires

[test] Update epoch rewind test to allow EOP replay policy #473

Sign in to view logs

[test] Update epoch rewind test to allow EOP replay policy

[test] Update epoch rewind test to allow EOP replay policy #473

Triggered via push March 7, 2026 05:45
@pthirunpthirun
pushed e879e41
feature/rewind-epoch-passthrough
Status Failure
Total duration 21m 51s
Artifacts 19

VeniceCI-StaticAnalysisAndUnitTests.yml

on: push
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
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
3s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

52 errors
StaticAnalysis (17)
Process completed with exit code 1.
TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L123
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.venice.controller.TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl(TestVeniceParentHelixAdminWithAcl.java:123) 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.testUpdateAndGetAndDeleteAcl: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L123
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.venice.controller.TestVeniceParentHelixAdminWithAcl.testUpdateAndGetAndDeleteAcl(TestVeniceParentHelixAdminWithAcl.java:123) 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
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: Class KafkaKey has a memoryAllocatedPerInstance (81.94304) which is too far from the predictedUsage (40); delta: 1.049; maxAllowedDelta: 0.012. No more 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: Class KafkaKey has a memoryAllocatedPerInstance (81.94304) which is too far from the predictedUsage (40); delta: 1.049; maxAllowedDelta: 0.012. No more attempts left.
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:558) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2950)
KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1
java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L195
java.lang.AssertionError: expected [true] but found [false]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153
java.lang.AssertionError: expected [NaN] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49
java.lang.AssertionError: expected [1024.0] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24
java.lang.AssertionError: expected [1024.0] but found [0.0]
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:558) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2950)
KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1
java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L195
java.lang.AssertionError: expected [true] but found [false]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153
java.lang.AssertionError: expected [NaN] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49
java.lang.AssertionError: expected [1024.0] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24
java.lang.AssertionError: expected [1024.0] but found [0.0]
KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1
java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153
java.lang.AssertionError: expected [NaN] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49
java.lang.AssertionError: expected [1024.0] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24
java.lang.AssertionError: expected [1024.0] but found [0.0]
KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1
java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153
java.lang.AssertionError: expected [NaN] but found [0.0]
StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277
java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]
AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167
java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 312ms expected [true] but found [false]
StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277
java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]
AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167
java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 312ms expected [true] but found [false]
StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277
java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]
AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167
java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 478ms expected [true] but found [false]
StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277
java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]
AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167
java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 478ms expected [true] but found [false]
StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277
java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]
AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167
java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 468ms expected [true] but found [false]
PartitionedProducerExecutorTest.testWorkersEnabledDifferentPartitionsParallel: clients/venice-producer/src/test/java/com/linkedin/venice/producer/PartitionedProducerExecutorTest.java#L137
java.lang.AssertionError: Partitions should execute in parallel expected [true] but found [false]
StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277
java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]
AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167
java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 468ms expected [true] but found [false]
PartitionedProducerExecutorTest.testWorkersEnabledDifferentPartitionsParallel: clients/venice-producer/src/test/java/com/linkedin/venice/producer/PartitionedProducerExecutorTest.java#L137
java.lang.AssertionError: Partitions should execute in parallel expected [true] but found [false]
RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49
java.lang.AssertionError: expected [1024.0] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24
java.lang.AssertionError: expected [1024.0] but found [0.0]
KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1
java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]
KafkaConsumerServiceDelegatorTest.testKafkaConsumerServiceResubscriptionConcurrency: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java#L368
java.lang.AssertionError: Found race condition in KafkaConsumerService with time passed in milliseconds: 2784 expected [false] but found [true]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153
java.lang.AssertionError: expected [NaN] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49
java.lang.AssertionError: expected [1024.0] but found [0.0]
RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24
java.lang.AssertionError: expected [1024.0] but found [0.0]
KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1
java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]
KafkaConsumerServiceDelegatorTest.testKafkaConsumerServiceResubscriptionConcurrency: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaConsumerServiceDelegatorTest.java#L368
java.lang.AssertionError: Found race condition in KafkaConsumerService with time passed in milliseconds: 2784 expected [false] but found [true]
StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153
java.lang.AssertionError: expected [NaN] but found [0.0]
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis Expired
956 KB
sha256:e1ae68291af9ef1adc8ea8a92ae0d2e6af79445b0c2e238cebe7b34ae9680b3c
clients-jdk11 Expired
3.22 MB
sha256:53010a5e49012a3611d3854b46fdce53fb801ebdf262c33729c86d637c12acd2
clients-jdk17 Expired
3.23 MB
sha256:2ee79d6150dede69844cee18910e32ac1eed5874c1f8a87c9414f4c46c38d8f3
clients-jdk8 Expired
3.18 MB
sha256:3e2398685d9d61fbf0740506dc5bca30c8e5663f5215f82451fef3cad476726e
controller-jdk11 Expired
2.12 MB
sha256:52cbbb6a40243197b6b9dde00f9c0dadf083d8c222b85032ec49613516efe579
controller-jdk17 Expired
2.12 MB
sha256:52c5ee4405f24dc436f7dcd282491363ff598479ba046311fbd05e539f22c0e2
controller-jdk8 Expired
2.09 MB
sha256:77b6cb369df0f5d8b4f563ef2829d7451b44e0c20c84d2c060607e54e131fc37
integrations-jdk11 Expired
614 KB
sha256:8c1a25d7b68c083fb7aa762bb7f79c99a0aa71957d02d7da958a74780813a667
integrations-jdk17 Expired
619 KB
sha256:98340264d3562d2b19e6d0009dc6967869ab51a74176cac3e77ab0facdd2b48c
integrations-jdk8 Expired
600 KB
sha256:4e942fae50937fee3839cb03de4044b589b9d13aba7f4918428f242972028aa3
internal-jdk11 Expired
4.45 MB
sha256:9804fb259700928d16076a64ce248f6050e0bfdf042ee3dd29167649d2d10bdc
internal-jdk17 Expired
4.46 MB
sha256:45e07fb49f20034c905442c7e9205968b85a9642a418901ce07acb83d8d3e6f6
internal-jdk8 Expired
4.43 MB
sha256:e9d7c08a5d55852591dc3bb73b0cbdfba856be1c8234838d8aebe3100004003b
router-jdk11 Expired
776 KB
sha256:d0ba2299ef310774ec44038f253ad29c2d49d00cb38b0c9b66d922104e64f1e4
router-jdk17 Expired
782 KB
sha256:26a13aa25c3b34dd4e15579f23bedf6bef778ced3eeccd13c4267f708ad8770b
router-jdk8 Expired
765 KB
sha256:464744300d8016a32e99504e499207bcf01ff15c531a70799aced1381e2d7de3
server-jdk11 Expired
11.3 MB
sha256:bd3a45ca91f41526ca112b895f453d4fb31f766d550188ecb5991e4f86508f74
server-jdk17 Expired
11.1 MB
sha256:db95da61a93d1ceb10dc8246d55b42bed342edaae3fc83d73c6d2299f4428137
server-jdk8 Expired
10.9 MB
sha256:acbb731468354e3210b4fdd68dc6f29f81da807f068c9682e66b4faa959f3833