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 @@
   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 @@
     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