ApplicationManager applicationManager = deployApplication(TestFlowStreamIntegrationApp.class);
StreamManager s1 = getStreamManager("s1");
for (int i = 0; i < 50; i++) {
s1.send(String.valueOf(i));
}
<BUG>applicationManager.startFlow("StreamTestFlow");
</BUG>
RuntimeMetrics flowletMetrics1 = RuntimeStats.getFlowletMetrics("TestFlowStreamIntegrationApp",
"StreamTestFlow", "StreamReader");
flowletMetrics1.waitForProcessed(1, 10, TimeUnit.SECONDS);

ApplicationManager applicationManager = deployApplication(TestFlowStreamIntegrationApp.class);
StreamManager s1 = getStreamManager("s1");
for (int i = 0; i < 50; i++) {
s1.send(String.valueOf(i));
}
applicationManager.getFlowManager("StreamTestFlow").start();
RuntimeMetrics flowletMetrics1 = RuntimeStats.getFlowletMetrics("TestFlowStreamIntegrationApp",
"StreamTestFlow", "StreamReader");
flowletMetrics1.waitForProcessed(1, 10, TimeUnit.SECONDS);
