<BUG>FlowManager flowManager = appManager.getFlowManager("PointsFlow");flowManager.start();</BUG><CONTEXT>import java.util.concurrent.TimeUnit;public class SparkKMeansAppTest extends TestBase {@Testpublic void test() throws Exception {ApplicationManager appManager = deployApplication(SparkKMeansApp.class);<extra_id_0>StreamManager streamManager = getStreamManager("pointsStream");streamManager.send("10.6 519.2 110.3");</CONTEXT>
FlowManager flowManager = appManager.getFlowManager("PointsFlow").start();