Repository: samza Updated Branches: refs/heads/master ff3717ddc -> 2f1003bc1
Fix broken tests caused due to merging Due to interleaved ordering of the PRs (https://github.com/apache/samza/pull/675 and https://github.com/apache/samza/pull/673), FaultInjectionTest is broken. Author: bharathkk <[email protected]> Reviewers: Shanthoosh Venkatraman <[email protected]> Closes #700 from bharathkk/fix-trunk Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/2f1003bc Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/2f1003bc Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/2f1003bc Branch: refs/heads/master Commit: 2f1003bc181853fadad88c91950284bf9468c8af Parents: ff3717d Author: bharathkk <[email protected]> Authored: Mon Oct 8 16:39:01 2018 -0700 Committer: Prateek Maheshwari <[email protected]> Committed: Mon Oct 8 16:39:01 2018 -0700 ---------------------------------------------------------------------- .../java/org/apache/samza/test/framework/FaultInjectionTest.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/2f1003bc/samza-test/src/test/java/org/apache/samza/test/framework/FaultInjectionTest.java ---------------------------------------------------------------------- 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 2dc76a4..7deb4d7 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 class FaultInjectionTest extends StreamApplicationIntegrationTestHarness CountDownLatch containerShutdownLatch = new CountDownLatch(1); Map<String, String> 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");
