@Test
public void testSparkWithService() throws Exception {
ApplicationManager applicationManager = deployApplication(TestSparkServiceIntegrationApp.class);
startService(applicationManager);
SparkManager sparkManager = applicationManager.getSparkManager(
<BUG>TestSparkServiceIntegrationApp.SparkServiceProgram.class.getSimpleName());

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

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