ApplicationManager applicationManager = deployApplication(TestSparkStreamIntegrationApp.class);
StreamManager streamManager = getStreamManager("testStream");
for (int i = 0; i < 50; i++) {
streamManager.send(String.valueOf(i));
}
<BUG>SparkManager sparkManager = applicationManager.getSparkManager("SparkStreamProgram");

sparkManager.start();</BUG>
sparkManager.waitForFinish(120, TimeUnit.SECONDS);
DataSetManager<KeyValueTable> datasetManager = applicationManager.getDataSet("result");

ApplicationManager applicationManager = deployApplication(TestSparkStreamIntegrationApp.class);
StreamManager streamManager = getStreamManager("testStream");
for (int i = 0; i < 50; i++) {
streamManager.send(String.valueOf(i));
}
SparkManager sparkManager = applicationManager.getSparkManager("SparkStreamProgram").start();
sparkManager.waitForFinish(120, TimeUnit.SECONDS);
DataSetManager<KeyValueTable> datasetManager = applicationManager.getDataSet("result");
