You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2017/04/07 20:43:54 UTC
apex-core git commit: APEXCORE-677 Avoid starting StramLocalCluster
in StreamingContainerManagerTest.testAppDataSources
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 <v....@datatorrent.com>
Authored: Tue Mar 21 19:17:12 2017 -0700
Committer: Vlad Rozov <v....@datatorrent.com>
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