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.startFlow("PointsFlow");

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

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");
flowManager.start();
StreamManager streamManager = getStreamManager("pointsStream");
streamManager.send("10.6 519.2 110.3");
streamManager.send("10.6 518.1 110.1");
