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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

Controller / UT & CodeCov (11)

Process completed with exit code 1.

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

Controller / UT & CodeCov (17)

Process completed with exit code 1.

AbstractPartitionWriterThrottlingTest.testThrottlingDoesNotBlockBelowQuota: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/task/datawriter/AbstractPartitionWriterThrottlingTest.java#L167

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 345ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 261ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 238ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 302ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 458ms expected [true] but found [false]

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

Clients / UT & CodeCov (17)

Process completed with exit code 1.

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 247ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 273ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 238ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 252ms expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 443ms expected [true] but found [false]

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

Clients / UT & CodeCov (11)

Process completed with exit code 1.

InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49

java.lang.AssertionError: Memory allocated is negative! memoryAllocatedBeforeInstantiations: 2428707048; memoryAllocatedAfterInstantiations: 2423626984; memoryAllocatedByInstantiations: -5080064; 3 attempts left.

InstanceSizeEstimatorTest.testInstanceMeasurement: internal/venice-common/src/test/java/com/linkedin/venice/memory/InstanceSizeEstimatorTest.java#L49

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]

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

PartitionedProducerExecutorTest.testWorkersEnabledDifferentPartitionsParallel: clients/venice-producer/src/test/java/com/linkedin/venice/producer/PartitionedProducerExecutorTest.java#L137

java.lang.AssertionError: Partitions should execute in parallel expected [true] but found [false]

StatTrackingStoreClientTest.testMultiGet: clients/venice-thin-client/src/test/java/com/linkedin/venice/client/store/StatTrackingStoreClientTest.java#L277

java.lang.AssertionError: Success Key Ratio should be positive expected [true] but found [false]

java.lang.AssertionError: Messages should not be throttled when below quota, elapsed: 310ms expected [true] but found [false]

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

TestKafkaFormatTopicAutoDiscover.testUserProvidedEpochRewindWithInvalidRemotePolicy: clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java#L108

java.lang.AssertionError: Expected Throwable to be thrown, but nothing was thrown

PartitionedProducerExecutorTest.testWorkersEnabledDifferentPartitionsParallel: clients/venice-producer/src/test/java/com/linkedin/venice/producer/PartitionedProducerExecutorTest.java#L137

java.lang.AssertionError: Partitions should execute in parallel expected [true] but found [false]

Clients / UT & CodeCov (8)

Process completed with exit code 1.

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

AdminConsumptionTaskTest.cleanUp: services/venice-controller/src/test/java/com/linkedin/venice/controller/kafka/consumer/AdminConsumptionTaskTest.java#L224

java.lang.AssertionError: expected [true] but found [false]

AdminConsumptionTaskTest.testAddVersionMsgHandlingForTargetedRegionPush: 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

TestVeniceParentHelixAdminWithAcl.testStoreCreationWithAuthorization: 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

Controller / UT & CodeCov (8)

Process completed with exit code 1.

RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49

java.lang.AssertionError: expected [1024.0] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24

java.lang.AssertionError: expected [1024.0] but found [0.0]

KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.testAAWCThreadPoolStatsAreRegistered: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/KafkaStoreIngestionServiceWithStoreAwarePartitionWiseTest.java#L1

java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]

StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153

java.lang.AssertionError: expected [NaN] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49

java.lang.AssertionError: expected [1024.0] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24

java.lang.AssertionError: expected [1024.0] but found [0.0]

java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]

StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153

java.lang.AssertionError: expected [NaN] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49

java.lang.AssertionError: expected [1024.0] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24

java.lang.AssertionError: expected [1024.0] but found [0.0]

java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]

StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153

java.lang.AssertionError: expected [NaN] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49

java.lang.AssertionError: expected [1024.0] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24

java.lang.AssertionError: expected [1024.0] but found [0.0]

java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]

StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153

java.lang.AssertionError: expected [NaN] but found [0.0]

SITWithPWiseAndBufferAfterLeaderTest.methodSetUp: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue: 'recordTotalPollRequestLatency' 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.

java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]

StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153

java.lang.AssertionError: expected [NaN] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheReportsLiveUsageValues: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L49

java.lang.AssertionError: expected [1024.0] but found [0.0]

RocksDBMemoryStatsTest.testSetRMDBlockCacheRegistersGauges: clients/da-vinci-client/src/test/java/com/linkedin/davinci/stats/RocksDBMemoryStatsTest.java#L24

java.lang.AssertionError: expected [1024.0] but found [0.0]

SITWithSAwarePWiseAndBufferAfterLeaderTest.testRecordLevelMetricForCurrentVersion[0](false): clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithSAwarePWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.verification.TooFewActualInvocations: hostLevelIngestionStats.recordTotalBytesConsumed( <any long> ); Wanted 2 times: -> at com.linkedin.davinci.stats.HostLevelIngestionStats.recordTotalBytesConsumed(HostLevelIngestionStats.java:558) But was 1 time: -> at com.linkedin.davinci.kafka.consumer.StoreIngestionTask.processConsumerRecord(StoreIngestionTask.java:2950)

SITWithPWiseAndBufferAfterLeaderTest.methodCleanUp: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1

org.mockito.exceptions.misusing.CannotStubVoidMethodWithReturnValue: 'recordTotalAvgPartitionsPerConsumer' 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.methodSetUp: clients/da-vinci-client/src/test/java/com/linkedin/davinci/kafka/consumer/SITWithPWiseAndBufferAfterLeaderTest.java#L1

java.lang.AssertionError: AA/WC parallel processing thread pool should have 4 threads expected [4] but found [0]

StoreBackendTest.testSubscribeCurrentVersion: clients/da-vinci-client/src/test/java/com/linkedin/davinci/StoreBackendTest.java#L153

java.lang.AssertionError: expected [NaN] but found [0.0]

StaticAnalysisAndUnitTestsFailureAlert

Process completed with exit code 1.

Artifacts

Produced during runtime

Name	Size	Digest
StaticAnalysis Expired	956 KB	`sha256:561a616738cb87bd88e2edfa927b5163ef6041fa7a5d5a1662a4ec00660e81c5`
clients-jdk11 Expired	2.35 MB	`sha256:3db2659807c78fb795f8d440e4e854df8d0429fd58634daab01ad304808a0ae7`
clients-jdk17 Expired	2.36 MB	`sha256:0b91041241bd509fa53bbefdabdac2a5ffcc495dfddf98fd6e9af46fcd520ee2`
clients-jdk8 Expired	2.32 MB	`sha256:6f234d31898998fc566af155d344189102ed38ea3378b19de2c5c32d956e03fb`
controller-jdk11 Expired	708 KB	`sha256:ff538cd43435372e67543a677c575db70f0d880290eb5939ce930072c3453770`
controller-jdk17 Expired	688 KB	`sha256:ff1e2b0eb7cdea0b5e4b54b99740b9b0fa4cbaacee87eafdd30dec92a6689453`
controller-jdk8 Expired	719 KB	`sha256:35bd3d06414d80b5fa268e41c007c5e51ccbd46f3347ebdb68c0ae0ecf0ecb91`
integrations-jdk11 Expired	608 KB	`sha256:a078410f811076e9d85c65c75804234ff9fc6fefb1bd12b86b2401acc19f7667`
integrations-jdk17 Expired	619 KB	`sha256:b89a187048a9254e4f048e7cebf391d03b6f8c369d64276c514e7dca097d70ae`
integrations-jdk8 Expired	600 KB	`sha256:a4f05f4787b2345f9bd0be3f578c09bf011b4dd2facf2a90753d67c9e2b0493e`
internal-jdk11 Expired	4.44 MB	`sha256:b1223e3ce93b255ddd9e89e54163075f3bc50d1ce6e2b61eade4ed98e3d7460e`
internal-jdk17 Expired	4.46 MB	`sha256:5892d5b6368d95505fc83a742464f51af745fc58bb23b6f855ff90536a116b14`
internal-jdk8 Expired	4.43 MB	`sha256:c8bda817e08f4658e542c612e0b31a1e83679d42a49c510c38649a2da0ad07cb`
router-jdk11 Expired	776 KB	`sha256:e5a1606210c9b2f3713b2a8a09e6b4fd3ee985ea2eb01933bb3c7c7dabd5a10e`
router-jdk17 Expired	778 KB	`sha256:7dff66cf46960c97a02c400215f444c98e2bc170d6566b3d8b8aa8b2ea8890b0`
router-jdk8 Expired	771 KB	`sha256:710c704dc03a8a5efb083d5f7c56c98455782a75c847074aa20ba675d08ddc0e`
server-jdk11 Expired	11.3 MB	`sha256:28334425c1224bfd128c6a8632f7416bc65b957ff61d95dca5dedc6a8875c38d`
server-jdk17 Expired	12.3 MB	`sha256:bd1733365377f4ab6c84c410e0d24f0f638fc7889bcd227cba38f38d78611869`
server-jdk8 Expired	11 MB	`sha256:437a3b291e90c7393f125acca6125ecc1f9ae758747772899c31687bbc8a195c`

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[controller] Add rewindEpochTimeInSecondsOverride to pass absolute epoch #470

Summary

[controller] Add rewindEpochTimeInSecondsOverride to pass absolute epoch #470

Uh oh!

VeniceCI-StaticAnalysisAndUnitTests.yml

Annotations

Artifacts