diff --git a/samza-test/src/test/java/org/apache/samza/test/framework/FaultInjectionTest.java b/samza-test/src/test/java/org/apache/samza/test/framework/FaultInjectionTest.java index 2dc76a440f..7deb4d70ab 100644 --- a/samza-test/src/test/java/org/apache/samza/test/framework/FaultInjectionTest.java +++ b/samza-test/src/test/java/org/apache/samza/test/framework/FaultInjectionTest.java @@ -54,7 +54,6 @@ public void testRaceCondition() throws InterruptedException { CountDownLatch containerShutdownLatch = new CountDownLatch(1); Map configs = new HashMap<>(); configs.put(JobCoordinatorConfig.JOB_COORDINATOR_FACTORY, "org.apache.samza.zk.ZkJobCoordinatorFactory"); - configs.put(JobCoordinatorConfig.JOB_COORDINATION_UTILS_FACTORY, "org.apache.samza.zk.ZkCoordinationUtilsFactory"); configs.put(JobConfig.PROCESSOR_ID(), "0"); configs.put(TaskConfig.GROUPER_FACTORY(), "org.apache.samza.container.grouper.task.GroupByContainerIdsFactory"); configs.put(FaultInjectionStreamApp.INPUT_TOPIC_NAME_PROP, "page-views");