private static final Logger LOG = LoggerFactory.getLogger(SparkServiceIntegrationTestRun.class);
@Test
public void testSparkWithService() throws Exception {
ApplicationManager applicationManager = deployApplication(TestSparkServiceIntegrationApp.class);
startService(applicationManager);
<BUG>SparkManager sparkManager = applicationManager.startSpark(

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

private static final Logger LOG = LoggerFactory.getLogger(SparkServiceIntegrationTestRun.class);
@Test
public void testSparkWithService() throws Exception {
ApplicationManager applicationManager = deployApplication(TestSparkServiceIntegrationApp.class);
startService(applicationManager);
SparkManager sparkManager = applicationManager.getSparkManager(
TestSparkServiceIntegrationApp.SparkServiceProgram.class.getSimpleName());
sparkManager.start();
sparkManager.waitForFinish(120, TimeUnit.SECONDS);
DataSetManager<KeyValueTable> datasetManager = applicationManager.getDataSet("result");
