Skip to content

cleanup

cleanup #435

Triggered via push February 3, 2026 01:31
Status Failure
Total duration 2h 41m 14s
Artifacts 19
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
12s
ValidateGradleWrapper
StaticAnalysisAndUnitTestsFailureAlert
3s
StaticAnalysisAndUnitTestsFailureAlert
Fit to window
Zoom out
Zoom in

Annotations

56 errors
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
Controller / UT & CodeCov (11)
Process completed with exit code 1.
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
Controller / UT & CodeCov (8)
Process completed with exit code 1.
ApacheKafkaConsumerAdapterTest.testPollHoldsLockBlocksPauseUntilPollReturns: internal/venice-common/src/test/java/com/linkedin/venice/pubsub/adapter/kafka/consumer/ApacheKafkaConsumerAdapterTest.java#L965
java.lang.AssertionError: pause should complete after poll returned, proving mutual exclusion expected [true] but found [false]
ApacheKafkaConsumerAdapterTest.testPollHoldsLockBlocksPauseUntilPollReturns: internal/venice-common/src/test/java/com/linkedin/venice/pubsub/adapter/kafka/consumer/ApacheKafkaConsumerAdapterTest.java#L965
java.lang.AssertionError: pause should complete after poll returned, proving mutual exclusion expected [true] but found [false]
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
TestVeniceHelixAdmin.testCreateOrUpdateRealTimeTopic: services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceHelixAdmin.java#L312
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted: topicManager.createTopic( test-store_rt, 10, <any integer>, <any long>, <any boolean>, <any java.util.Optional>, <any boolean> ); -> at com.linkedin.venice.pubsub.manager.TopicManager.createTopic(TopicManager.java:191) Actual invocations have different arguments: topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.containsTopic( test-store_rt ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3575) topicManager.createTopic( test-store_rt, 10, 0, 432000000L, false, Optional.empty, Optional.empty, false ); -> at com.linkedin.venice.controller.VeniceHelixAdmin.createOrUpdateRealTimeTopic(VeniceHelixAdmin.java:3579)
Controller / UT & CodeCov (17)
Process completed with exit code 1.
InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2398150048; memoryAllocatedAfterInstantiations: 2390421408; memoryAllocatedByInstantiations: -7728640; 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: 2398150048; memoryAllocatedAfterInstantiations: 2390421408; memoryAllocatedByInstantiations: -7728640; 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:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
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:523) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
ServerConnectionStatsHandlerTest.testChannelRegisteredUnregisteredWithSslHandler: services/venice-server/src/test/java/com/linkedin/venice/listener/ServerConnectionStatsHandlerTest.java#L97
Wanted but not invoked: serverConnectionStats.decrementClientConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandlerTest.testChannelRegisteredUnregisteredWithSslHandler(ServerConnectionStatsHandlerTest.java:97) However, there were exactly 5 interactions with this mock: serverConnectionStats.newConnectionRequest(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.channelActive(ServerConnectionStatsHandler.java:96) serverConnectionStats.incrementRouterConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.lambda$new$0(ServerConnectionStatsHandler.java:74) serverConnectionStats.decrementRouterConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.channelInactive(ServerConnectionStatsHandler.java:113) serverConnectionStats.newConnectionRequest(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.channelActive(ServerConnectionStatsHandler.java:96) serverConnectionStats.incrementClientConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.lambda$new$0(ServerConnectionStatsHandler.java:76)
ServerConnectionStatsHandlerTest.testChannelRegisteredUnregisteredWithSslHandler: services/venice-server/src/test/java/com/linkedin/venice/listener/ServerConnectionStatsHandlerTest.java#L97
Wanted but not invoked: serverConnectionStats.decrementClientConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandlerTest.testChannelRegisteredUnregisteredWithSslHandler(ServerConnectionStatsHandlerTest.java:97) However, there were exactly 5 interactions with this mock: serverConnectionStats.newConnectionRequest(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.channelActive(ServerConnectionStatsHandler.java:96) serverConnectionStats.incrementRouterConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.lambda$new$0(ServerConnectionStatsHandler.java:74) serverConnectionStats.decrementRouterConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.channelInactive(ServerConnectionStatsHandler.java:113) serverConnectionStats.newConnectionRequest(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.channelActive(ServerConnectionStatsHandler.java:96) serverConnectionStats.incrementClientConnectionCount(); -> at com.linkedin.venice.listener.ServerConnectionStatsHandler.lambda$new$0(ServerConnectionStatsHandler.java:76)
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 254 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ed01de6cc_44baa8b8_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ed01de6cc_44baa8b8_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 675116015 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 675116015 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ed01de6cc_44baa8b8_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090741187}, Mock for Store, hashCode: 675116015 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ed01de6cc_44baa8b8_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090741187} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4ed01de6cc_44baa8b8_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 254 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ed01de6cc_44baa8b8_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_4ed01de6cc_44baa8b8_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 675116015 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 675116015 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ed01de6cc_44baa8b8_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090741187}, Mock for Store, hashCode: 675116015 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4ed01de6cc_44baa8b8_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090741187} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_4ed01de6cc_44baa8b8_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, l
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue: 'close' 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.
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 276 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_46457dafb2_378a75d3_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_46457dafb2_378a75d3_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 306518635 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 306518635 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_46457dafb2_378a75d3_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090794181}, Mock for Store, hashCode: 306518635 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_46457dafb2_378a75d3_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090794181} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_46457dafb2_378a75d3_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProce
SITWithSAwarePWiseAndBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.UnfinishedStubbingException: Unfinished stubbing detected here: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.lambda$testReportIfCatchUpVersionTopicOffset$189(StoreIngestionTaskTest.java:6257) 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
SITWithPWiseWithoutBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.java#L1
Wanted but not invoked: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) However, there were exactly 296 interactions with this mock: leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5353ea7983_c8ab6f9e_v1-1, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991) leaderFollowerStoreIngestionTask.subscribePartition( TestTopic_5353ea7983_c8ab6f9e_v1-1, true, Optional.empty ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:755) leaderFollowerStoreIngestionTask.throwIfNotRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:802) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.throwIfNotRunning(StoreIngestionTask.java:712) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.nextSeqNum(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.subscribePartition(StoreIngestionTask.java:808) leaderFollowerStoreIngestionTask.run(); -> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) leaderFollowerStoreIngestionTask.isRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1778) leaderFollowerStoreIngestionTask.getIsRunning(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.isRunning(StoreIngestionTask.java:4528) leaderFollowerStoreIngestionTask.refreshIngestionContextIfChanged( Mock for Store, hashCode: 1530049857 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1781) leaderFollowerStoreIngestionTask.maybeProcessResubscribeRequest(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1782) leaderFollowerStoreIngestionTask.getServerConfig(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5204) leaderFollowerStoreIngestionTask.getResubscribeRequestQueue(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.maybeProcessResubscribeRequest(StoreIngestionTask.java:5205) leaderFollowerStoreIngestionTask.processConsumerActions( Mock for Store, hashCode: 1530049857 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783) leaderFollowerStoreIngestionTask.processConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5353ea7983_c8ab6f9e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090850254}, Mock for Store, hashCode: 1530049857 ); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122) leaderFollowerStoreIngestionTask.processCommonConsumerAction( KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5353ea7983_c8ab6f9e_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770090850254} ); -> at com.linkedin.davinci.kafka.consumer.LeaderFollowerStoreIngestionTask.processConsumerAction(LeaderFollowerStoreIngestionTask.java:598) leaderFollowerStoreIngestionTask.getDataIntegrityValidator(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processCommonConsumerAction(StoreIngestionTask.java:2312) leaderFollowerStoreIngestionTask.isGlobalRtDivEnabled(); -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.getDataIntegrityValidator(StoreIngestionTask.java:5021) leaderFollowerStoreIngestionTask.checkFastReadyToServeForReplica( PCS{replica=TestTopic_5353ea7983_c8ab6f9e_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations: leaderFollowerStoreIngestionTask.reportIngestionNotifier( <any com.linkedin.davinci.kafka.consumer.PartitionConsumptionState>, <any com.linkedin.venice.exceptions.VeniceException> ); Wanted 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.reportIngestionNotifier(StoreIngestionTask.java:1612) But was 0 times.
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.

Artifacts

Produced during runtime
Name Size Digest
StaticAnalysis Expired
925 KB
sha256:2e98e355658270a4bea473e417b149e28808fa39a4e47eb9fc9bd3d2b7bfbfdd
clients-jdk11 Expired
3.19 MB
sha256:a46745e8ed0f091114f8e880fb725ae73f02ce081cfb0ebfdfc1b4307828be8e
clients-jdk17 Expired
3.19 MB
sha256:3c7912819e690e158b97b5e675b958565f1bcb80de3b14c3d2f03f41116ddaf8
clients-jdk8 Expired
3.14 MB
sha256:42f3db50f65353282e12123396d822e2856fdfd0494979381e11dc000e030fe6
controller-jdk11 Expired
613 KB
sha256:df0cbe74029497153d2a837016c3bb2ea405b1338937719f603eab91bb927381
controller-jdk17 Expired
612 KB
sha256:7ca45fe8dcfc0406541382292085a207140de174f48ba175fb5f4a149aaf9381
controller-jdk8 Expired
621 KB
sha256:05977e6c87c44cd3215663fce57d8c20687fe0d643e1bd00257395cf81a95196
integrations-jdk11 Expired
556 KB
sha256:72e9b4a6fde3bd0b0cec63c101ba552ad43be7cea854806db5aabe84f5910978
integrations-jdk17 Expired
556 KB
sha256:7a4fac561fcb0e2edcd16a090c2e9d34c12459f27a89cec8fa91fc9109dd3416
integrations-jdk8 Expired
543 KB
sha256:2fa98f3a23ed3183da2c15f03d5a13cc486ce00def5c6309eebe00a1e764f2f8
internal-jdk11 Expired
4.28 MB
sha256:5258495d0286471f32e3a3367e72203379bdcf1967dce8ce589c98853bb19821
internal-jdk17 Expired
4.29 MB
sha256:37bf554395f2e86e95bb5d510b828da220e01efb455efba03c0289f88a8a0d3f
internal-jdk8 Expired
4.26 MB
sha256:0e041b1f021ae994128e27d3f62e35490f5451f95dc45053d7b53e004a5e5c28
router-jdk11 Expired
767 KB
sha256:7ae8c64667e59a7f21af4921a188fe897596b9bf7feee3c4cadd05444960ab27
router-jdk17 Expired
771 KB
sha256:044bcb2eb0520567c698aa1e6f44a72a0116257a5d6a5fbfec97c17cc1ac3c42
router-jdk8 Expired
758 KB
sha256:01e1fe50dd7d04fe5f0d9353fa16cdf953d91485fcad232c5732e99dc0b97191
server-jdk11 Expired
10.4 MB
sha256:320e31bce3c90141acd42c681f5486c8d241ea5c383ccbeef69af6e4f44baa2c
server-jdk17 Expired
10.6 MB
sha256:151314163cf34ab7a7ef14a50ec4b47a361a9cf6e70fc41a3d2851c569f291a0
server-jdk8 Expired
10.7 MB
sha256:ccebc729f365bb51e59a9dde1ed14a24032932a9c9378535ee6f2329c4b7047b