[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_72e5bf0512_e9e197c",
"test_store_7139b4e18a_e81971b2",
"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_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_72e5bf0512_e9e197c"
);
-> 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_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_72e5bf0512_e9e197c"
);
-> 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_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_72e5bf0512_e9e197c",
"test_store_7139b4e18a_e81971b2",
"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_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_72e5bf0512_e9e197c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345
|
|
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_672dbc0dc2_8b41de02",
"test_store_6592c50de5_5c848a10",
"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_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_672dbc0dc2_8b41de02"
);
-> 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_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_672dbc0dc2_8b41de02"
);
-> 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_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_672dbc0dc2_8b41de02",
"test_store_6592c50de5_5c848a10",
"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_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_672dbc0dc2_8b41de02"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_672dbc0dc2_8b41de02"
);
-> 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_5b8d4699dc_82bd6d76",
"test_store_59aa8b8290_1b8fe7d8",
"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_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> 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_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> 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_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_5b8d4699dc_82bd6d76",
"test_store_59aa8b8290_1b8fe7d8",
"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_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_5b8d4699dc_82bd6d76"
);
-> 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_4f808604e2_cf17838b",
"test_store_4de8ca410f_6dea70d4",
"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_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_4f808604e2_cf17838b"
);
-> 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_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_4f808604e2_cf17838b"
);
-> 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_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_4f808604e2_cf17838b",
"test_store_4de8ca410f_6dea70d4",
"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_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_4f808604e2_cf17838b"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_4f808604e2_cf17838b"
);
-> 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_2cf885f6a1_a8fc3a5c",
"test_store_2afebde31f_7fbf947f",
"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_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> 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_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.getHelixVeniceClusterResources(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> 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_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask.call(AdminExecutionTask.java:128)
veniceHelixAdmin.addVersionAndStartIngestion(
"test-cluster_2cf885f6a1_a8fc3a5c",
"test_store_2afebde31f_7fbf947f",
"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_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.persistAdminTopicMetadata(AdminConsumptionTask.java:1080)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isAdminTopicConsumptionEnabled(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptionTask.java:345)
veniceHelixAdmin.isLeaderControllerFor(
"test-cluster_2cf885f6a1_a8fc3a5c"
);
-> at com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTask.run(AdminConsumptio
|
|
|
The logs for this run have expired and are no longer available.
Loading