pthirun
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
9s
StaticAnalysisAndUnitTestsFailureAlert
4s
Annotations
64 errors
|
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 (37.37644) which is too far from the predictedUsage (40); delta: 0.066; maxAllowedDelta: 0.027. No more attempts left.
|
|
InstanceSizeEstimatorTest.testInstanceMeasurement:
internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49
java.lang.AssertionError: Class KafkaKey has a memoryAllocatedPerInstance (37.37644) which is too far from the predictedUsage (40); delta: 0.066; maxAllowedDelta: 0.027. No more attempts left.
|
|
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.
|
|
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.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.methodSetUp:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.UnfinishedVerificationException:
Missing method call for verify(mock) here:
-> at com.linkedin.davinci.stats.AggKafkaConsumerServiceStats.recordTotalUpdateCurrentAssignmentLatency(AggKafkaConsumerServiceStats.java:68)
Example of correct verification:
verify(mock).doSomething()
Also, this error might show up because you verify either of: final/private/equals()/hashCode() methods.
Those methods *cannot* be stubbed/verified.
Mocking methods declared on non-public parent classes is not supported.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testVeniceMessagesProcessingWithSortedInputWithBlobMode[2](false, true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'put' is a *void method* and it *cannot* be stubbed with a *return value*!
Voids are usually stubbed with Throwables:
doThrow(exception).when(mock).someVoidMethod();
If you need to set the void method to do nothing you can use:
doNothing().when(mock).someVoidMethod();
For more information, check out the javadocs for Mockito.doNothing().
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. The method you are trying to stub is *overloaded*. Make sure you are calling the right overloaded version.
2. Somewhere in your test you are stubbing *final methods*. Sorry, Mockito does not verify/stub final methods.
3. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
4. Mocking methods declared on non-public parent classes is not supported.
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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 236 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5745a12b67_11173f37_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5745a12b67_11173f37_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:515)
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: 1516871764
);
-> 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: 1516871764
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5745a12b67_11173f37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084039932},
Mock for Store, hashCode: 1516871764
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5745a12b67_11173f37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084039932}
);
-> 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_5745a12b67_11173f37_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.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
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.methodSetUp:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.UnfinishedVerificationException:
Missing method call for verify(mock) here:
-> at com.linkedin.davinci.stats.AggKafkaConsumerServiceStats.recordTotalUpdateCurrentAssignmentLatency(AggKafkaConsumerServiceStats.java:68)
Example of correct verification:
verify(mock).doSomething()
Also, this error might show up because you verify either of: final/private/equals()/hashCode() methods.
Those methods *cannot* be stubbed/verified.
Mocking methods declared on non-public parent classes is not supported.
|
|
SITWithSAwarePWiseWithoutBufferAfterLeaderTest.testVeniceMessagesProcessingWithSortedInputWithBlobMode[2](false, true):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseWithoutBufferAfterLeaderTest.java#L1
org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue:
'put' is a *void method* and it *cannot* be stubbed with a *return value*!
Voids are usually stubbed with Throwables:
doThrow(exception).when(mock).someVoidMethod();
If you need to set the void method to do nothing you can use:
doNothing().when(mock).someVoidMethod();
For more information, check out the javadocs for Mockito.doNothing().
***
If you're unsure why you're getting above error read on.
Due to the nature of the syntax above problem might occur because:
1. The method you are trying to stub is *overloaded*. Make sure you are calling the right overloaded version.
2. Somewhere in your test you are stubbing *final methods*. Sorry, Mockito does not verify/stub final methods.
3. A spy is stubbed using when(spy.foo()).then() syntax. It is safer to stub spies -
- with doReturn|Throw() family of methods. More in javadocs for Mockito.spy() method.
4. Mocking methods declared on non-public parent classes is not supported.
|
|
SITWithPWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false):
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1
org.mockito.exceptions.verification.TooFewActualInvocations:
hostLevelIngestionStats.recordTotalBytesConsumed(
<any long>
);
Wanted 2 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 1 time:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithPWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.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 236 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5745a12b67_11173f37_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_5745a12b67_11173f37_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:515)
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: 1516871764
);
-> 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: 1516871764
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5745a12b67_11173f37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084039932},
Mock for Store, hashCode: 1516871764
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_5745a12b67_11173f37_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084039932}
);
-> 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_5745a12b67_11173f37_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
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]
|
|
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 226 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4caf34c291_b3b09bbd_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4caf34c291_b3b09bbd_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: 1359201920
);
-> 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: 1359201920
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4caf34c291_b3b09bbd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084468155},
Mock for Store, hashCode: 1359201920
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4caf34c291_b3b09bbd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084468155}
);
-> 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_4caf34c291_b3b09bbd_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
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 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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.testRecordLevelMetricForCurrentVersion[2](true):
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 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
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]
|
|
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 226 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4caf34c291_b3b09bbd_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_4caf34c291_b3b09bbd_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: 1359201920
);
-> 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: 1359201920
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4caf34c291_b3b09bbd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084468155},
Mock for Store, hashCode: 1359201920
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_4caf34c291_b3b09bbd_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084468155}
);
-> 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_4caf34c291_b3b09bbd_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[2](true):
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 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithPWiseWithoutBufferAfterLeaderTest.testReportIfCatchUpVersionTopicOffset:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseWithoutBufferAfterLeaderTest.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.testRecordLevelMetricForCurrentVersion[2](true):
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 3 times:
-> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:523)
But was 2 times:
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2781)
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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_3e89675565_3ce0be_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_3e89675565_3ce0be_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: 2136072231
);
-> 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: 2136072231
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3e89675565_3ce0be_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084494906},
Mock for Store, hashCode: 2136072231
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3e89675565_3ce0be_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084494906}
);
-> 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_3e89675565_3ce0be_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProcessedRem
|
|
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 276 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_546bdffee3_b3deb8fa_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_546bdffee3_b3deb8fa_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: 1349411604
);
-> 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: 1349411604
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_546bdffee3_b3deb8fa_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084588936},
Mock for Store, hashCode: 1349411604
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_546bdffee3_b3deb8fa_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084588936}
);
-> 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_546bdffee3_b3deb8fa_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
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_492d69fb08_8c4202a1_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_492d69fb08_8c4202a1_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: 1911480564
);
-> 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: 1911480564
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_492d69fb08_8c4202a1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084540609},
Mock for Store, hashCode: 1911480564
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_492d69fb08_8c4202a1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084540609}
);
-> 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_492d69fb08_8c4202a1_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
SITWithSAwarePWiseAndBufferAfterLeaderTest.testIngestionTaskForCurrentVersionResetExceptionReportError:
clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.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_3e89675565_3ce0be_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_3e89675565_3ce0be_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: 2136072231
);
-> 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: 2136072231
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3e89675565_3ce0be_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084494906},
Mock for Store, hashCode: 2136072231
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_3e89675565_3ce0be_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084494906}
);
-> 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_3e89675565_3ce0be_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestProcessedRem
|
|
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 276 interactions with this mock:
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_546bdffee3_b3deb8fa_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_546bdffee3_b3deb8fa_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: 1349411604
);
-> 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: 1349411604
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_546bdffee3_b3deb8fa_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084588936},
Mock for Store, hashCode: 1349411604
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_546bdffee3_b3deb8fa_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084588936}
);
-> 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_546bdffee3_b3deb8fa_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
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_492d69fb08_8c4202a1_v1-1,
Optional.empty
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTaskTest.runTest(StoreIngestionTaskTest.java:991)
leaderFollowerStoreIngestionTask.subscribePartition(
TestTopic_492d69fb08_8c4202a1_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: 1911480564
);
-> 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: 1911480564
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.run(StoreIngestionTask.java:1783)
leaderFollowerStoreIngestionTask.processConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_492d69fb08_8c4202a1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084540609},
Mock for Store, hashCode: 1911480564
);
-> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerActions(StoreIngestionTask.java:2122)
leaderFollowerStoreIngestionTask.processCommonConsumerAction(
KafkaTaskMessage{type=SUBSCRIBE, topicPartition=TestTopic_492d69fb08_8c4202a1_v1-1, attempts=1, sequenceNumber=1, createdTimestampInMs=1770084540609}
);
-> 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_492d69fb08_8c4202a1_v1-1, hybrid=false, latestProcessedVtPosition=InMemoryPubSubPosition{2}, latestPr
|
|
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.
|
|
StaticAnalysisAndUnitTestsFailureAlert
Process completed with exit code 1.
|
Artifacts
Produced during runtime
| Name | Size | Digest | |
|---|---|---|---|
|
StaticAnalysis
Expired
|
924 KB |
sha256:8bcaedd51dc17ac5b3866ca00cabdb901c7e3e01e69932a69ccad2917a290c06
|
|
|
clients-jdk11
Expired
|
3.19 MB |
sha256:825aab33a19cd153577a410671fdd37dd8587c3b5c64e26f555fe4f4a5ee86c7
|
|
|
clients-jdk17
Expired
|
3.19 MB |
sha256:53d939b542b4c92f389e277491e0426c35f8f9f7574228daac8ba553e753d0c5
|
|
|
clients-jdk8
Expired
|
3.16 MB |
sha256:8afffbd895113eb7b15b8561dcc2f49cbac9b7c5d93733daeeea19458f36f3fa
|
|
|
controller-jdk11
Expired
|
615 KB |
sha256:a660d4320fd24b1276db6ea8f912d5a7e7ba69c0c3e8a9f79ca49b984c59ab7c
|
|
|
controller-jdk17
Expired
|
611 KB |
sha256:5a05ae67cb2a39282445806531218adc09def32b5ab42ba548fe506e3761bc48
|
|
|
controller-jdk8
Expired
|
624 KB |
sha256:8217af14854105f8240e62647595f0251fd55b67a31df6a61306e845dfb2b021
|
|
|
integrations-jdk11
Expired
|
557 KB |
sha256:f7c1ed78a275cd57f31bc4d44919442b984784782dc3b71f99b8cf4f9ca01b1e
|
|
|
integrations-jdk17
Expired
|
561 KB |
sha256:af0db3fd0f39ceafcaa955dd69d96754aa5341b7eb272c63f07753b5ab64e2af
|
|
|
integrations-jdk8
Expired
|
541 KB |
sha256:3121c86892722af1e356d96696fa60947cb351ab3146bad666c42ebaa05774b3
|
|
|
internal-jdk11
Expired
|
4.28 MB |
sha256:49105817430b81b0f8bdbba7544caab7ff788c03456f30289f446aabc2aa26f9
|
|
|
internal-jdk17
Expired
|
4.29 MB |
sha256:1ce244729f780ac389e05e1d8e0fd3398ebc7fde208e216f22a3c8c40d0fa3b5
|
|
|
internal-jdk8
Expired
|
4.26 MB |
sha256:d42311cb7418c041e2a11ff916ad3d4fb32b844f8e71fb8d5d06daa3f5db2a1c
|
|
|
router-jdk11
Expired
|
767 KB |
sha256:0f6d3b403b0e0d712109bb596eb01e3b2b4ec5123d7c5bd3c7a49ab335b6a274
|
|
|
router-jdk17
Expired
|
772 KB |
sha256:503d1a2e9f3ad9c75d4bf0241350675a8e6ed715d7c420614b5685fbc15ab010
|
|
|
router-jdk8
Expired
|
760 KB |
sha256:5810c4c306c53a58be23a070622e9d60b3f66d4a0eb48076bf6284bebe453139
|
|
|
server-jdk11
Expired
|
11.5 MB |
sha256:d1d30c051ab40a63cfbb7ef68255c06ca19f755d6143144b4a4880db3c37038b
|
|
|
server-jdk17
Expired
|
10.6 MB |
sha256:69b2bfdfdca1a1fb771688b51fd374a07ce15977cdc9090aa237ebb6d2938f12
|
|
|
server-jdk8
Expired
|
10.3 MB |
sha256:d37beed06b273c2221fc23b526c5325dc1bbdfbea97733bf3537574f15a031aa
|
|