bump version and fix unit test

Author: albertshau

pom.xml

@@ -22,7 +22,7 @@
 
   <groupId>io.cdap.plugin</groupId>
   <artifactId>dynamic-spark</artifactId>
-  <version>2.2.1</version>
+  <version>2.2.2</version>
 
   <properties>
     <!-- properties for script build step that creates the config files for the artifacts -->

src/test/java/io/cdap/plugin/spark/dynamic/ScalaSparkTest.java

@@ -161,8 +161,7 @@ public void testScalaProgram() throws Exception {
     Map<String, String> runtimeArgs = new HashMap<>(RuntimeArguments.addScope(Scope.DATASET, "text", inputArgs));
 
     WorkflowManager workflowManager = appManager.getWorkflowManager(SmartWorkflow.NAME);
-    workflowManager.start(runtimeArgs);
-    workflowManager.waitForRun(ProgramRunStatus.COMPLETED, 5, TimeUnit.MINUTES);
+    workflowManager.startAndWaitForRun(runtimeArgs, ProgramRunStatus.COMPLETED, 5, TimeUnit.MINUTES);
 
     // Validate the result
     KeyValueTable kvTable = this.<KeyValueTable>getDataset("kvTable").get();