import java.util.concurrent.TimeUnit;
public class HelloWorldTest extends TestBase {
@Test
public void test() throws Exception {
ApplicationManager appManager = deployApplication(HelloWorld.class);
<BUG>FlowManager flowManager = appManager.getFlowManager("WhoFlow");

flowManager.start();</BUG>
Assert.assertTrue(flowManager.isRunning());
StreamManager streamManager = getStreamManager("who");

import java.util.concurrent.TimeUnit;
public class HelloWorldTest extends TestBase {
@Test
public void test() throws Exception {
ApplicationManager appManager = deployApplication(HelloWorld.class);
FlowManager flowManager = appManager.getFlowManager("WhoFlow").start();
Assert.assertTrue(flowManager.isRunning());
StreamManager streamManager = getStreamManager("who");
