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

flowManager.start();</BUG>
StreamManager streamManager = getStreamManager("pointsStream");
streamManager.send("10.6 519.2 110.3");

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