[controller] Add rewindEpochTimeInSecondsOverride to pass absolute epoch #470
Annotations
11 errors
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1770
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_ceac18dc4a_13a3c271",
"test_store_cd1dd72624_348bf70a",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
-1L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.VeniceHelixAdmin.addVersionAndStartIngestion(VeniceHelixAdmin.java:2551)
Actual invocations have different arguments:
veniceHelixAdmin.getLogContext(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:312)
veniceHelixAdmin.getTopicManager(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:324)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_ceac18dc4a_13a3c271",
"test_store_cd1dd72624_348bf70a",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
0L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.handleAddVersion(AdminExecutionTask.java:785)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ceac18dc4a_13a3c271"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224
java.lang.AssertionError: expected [true] but found [false]
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1770
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_c39150a7b1_df37f4bf",
"test_store_c1f53ecf2a_db13a5b6",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
-1L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.VeniceHelixAdmin.addVersionAndStartIngestion(VeniceHelixAdmin.java:2551)
Actual invocations have different arguments:
veniceHelixAdmin.getLogContext(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:312)
veniceHelixAdmin.getTopicManager(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:324)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_c39150a7b1_df37f4bf",
"test_store_c1f53ecf2a_db13a5b6",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
0L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.handleAddVersion(AdminExecutionTask.java:785)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_c39150a7b1_df37f4bf"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224
java.lang.AssertionError: expected [true] but found [false]
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1770
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_b888fa7252_2058a53f",
"test_store_b714c26db1_d4139c8a",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
-1L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.VeniceHelixAdmin.addVersionAndStartIngestion(VeniceHelixAdmin.java:2551)
Actual invocations have different arguments:
veniceHelixAdmin.getLogContext(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:312)
veniceHelixAdmin.getTopicManager(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:324)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_b888fa7252_2058a53f",
"test_store_b714c26db1_d4139c8a",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
0L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.handleAddVersion(AdminExecutionTask.java:785)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_b888fa7252_2058a53f"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224
java.lang.AssertionError: expected [true] but found [false]
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1770
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_ad63b078f9_480677d6",
"test_store_abe642ff8f_443d9d66",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
-1L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.VeniceHelixAdmin.addVersionAndStartIngestion(VeniceHelixAdmin.java:2551)
Actual invocations have different arguments:
veniceHelixAdmin.getLogContext(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:312)
veniceHelixAdmin.getTopicManager(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:324)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_ad63b078f9_480677d6",
"test_store_abe642ff8f_443d9d66",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
0L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.handleAddVersion(AdminExecutionTask.java:785)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_ad63b078f9_480677d6"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224
java.lang.AssertionError: expected [true] but found [false]
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L1770
org.mockito.exceptions.verification.ArgumentsAreDifferent: Argument(s) are different! Wanted:
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_89d8519c1c_38a2ba7d",
"test_store_882e6d5328_ef5162f5",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
-1L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.VeniceHelixAdmin.addVersionAndStartIngestion(VeniceHelixAdmin.java:2551)
Actual invocations have different arguments:
veniceHelixAdmin.getLogContext(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:312)
veniceHelixAdmin.getTopicManager(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.<init>(AdminConsumptionTask.java:324)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminOperationSystemStoreEnabled(
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.deserializeAdminOperation(AdminConsumptionTask.java:937)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_89d8519c1c_38a2ba7d",
"test_store_882e6d5328_ef5162f5",
"mock push job id",
1,
1,
BATCH,
null,
-1L,
0L,
1,
false,
"dc-0",
0,
0,
0
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.handleAddVersion(AdminExecutionTask.java:785)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_89d8519c1c_38a2ba7d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
services/venice-controller/src/test/java/com/linkedin/venice/controller/TestVeniceParentHelixAdminWithAcl.java#L74
com.linkedin.venice.exceptions.VeniceNoStoreException: Store: test-store-authorizer does not exist in cluster test-cluster
|
|
|
The logs for this run have expired and are no longer available.
Loading