[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#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_881438b883_d486a53b",
"test_store_864c65b07d_ea8a3a69",
"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_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_881438b883_d486a53b"
);
-> 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_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_881438b883_d486a53b"
);
-> 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_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_881438b883_d486a53b",
"test_store_864c65b07d_ea8a3a69",
"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_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_881438b883_d486a53b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_881438b883_d486a53b"
);
-> 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_7c2c158bef_2575c34c",
"test_store_7a5eb66485_e3cc5467",
"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_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_7c2c158bef_2575c34c"
);
-> 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_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_7c2c158bef_2575c34c"
);
-> 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_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_7c2c158bef_2575c34c",
"test_store_7a5eb66485_e3cc5467",
"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_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_7c2c158bef_2575c34c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7c2c158bef_2575c34c"
);
-> 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_7037b5702a_1eb6e50d",
"test_store_6e5fbb9904_83923d69",
"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_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_7037b5702a_1eb6e50d"
);
-> 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_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_7037b5702a_1eb6e50d"
);
-> 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_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_7037b5702a_1eb6e50d",
"test_store_6e5fbb9904_83923d69",
"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_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_7037b5702a_1eb6e50d"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_7037b5702a_1eb6e50d"
);
-> 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_63f6618e60_e1f4dc10",
"test_store_6260888498_db0c1df3",
"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_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_63f6618e60_e1f4dc10"
);
-> 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_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_63f6618e60_e1f4dc10"
);
-> 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_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_63f6618e60_e1f4dc10",
"test_store_6260888498_db0c1df3",
"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_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_63f6618e60_e1f4dc10"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_63f6618e60_e1f4dc10"
);
-> 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_3e8c266212_5522ce5c",
"test_store_3c23c7ac90_b6147366",
"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_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_3e8c266212_5522ce5c"
);
-> 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_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_3e8c266212_5522ce5c"
);
-> 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_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_3e8c266212_5522ce5c",
"test_store_3c23c7ac90_b6147366",
"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_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_3e8c266212_5522ce5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
|
The logs for this run have expired and are no longer available.
Loading