Repository: apex-core Updated Branches: refs/heads/master 869e166e1 -> 938361374
APEXCORE-677 Avoid starting StramLocalCluster in StreamingContainerManagerTest.testAppDataSources Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/93836137 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/93836137 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/93836137 Branch: refs/heads/master Commit: 9383613741d6614a613bcbf9a41f4648cf22c147 Parents: 869e166 Author: Vlad Rozov <[email protected]> Authored: Tue Mar 21 19:17:12 2017 -0700 Committer: Vlad Rozov <[email protected]> Committed: Fri Apr 7 13:42:47 2017 -0700 ---------------------------------------------------------------------- .../java/com/datatorrent/stram/StreamingContainerManagerTest.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/93836137/engine/src/test/java/com/datatorrent/stram/StreamingContainerManagerTest.java ---------------------------------------------------------------------- diff --git a/engine/src/test/java/com/datatorrent/stram/StreamingContainerManagerTest.java b/engine/src/test/java/com/datatorrent/stram/StreamingContainerManagerTest.java index 84622c4..c606f47 100644 --- a/engine/src/test/java/com/datatorrent/stram/StreamingContainerManagerTest.java +++ b/engine/src/test/java/com/datatorrent/stram/StreamingContainerManagerTest.java @@ -875,7 +875,6 @@ public class StreamingContainerManagerTest private void testAppDataSources(boolean appendQIDToTopic) throws Exception { StramLocalCluster lc = new StramLocalCluster(dag); - lc.runAsync(); StreamingContainerManager dnmgr = lc.dnmgr; List<AppDataSource> appDataSources = dnmgr.getAppDataSources(); Assert.assertEquals("There should be exactly one data source", 1, appDataSources.size()); @@ -890,7 +889,6 @@ public class StreamingContainerManagerTest Assert.assertEquals("Result topic verification", "xyz.result", result.topic); Assert.assertEquals("Result URL verification", "ws://123.123.123.124:9090/pubsub", result.url); Assert.assertEquals("Result QID append verification", appendQIDToTopic, result.appendQIDToTopic); - lc.shutdown(); } @Test
