Skip to content

Commit b761cdc

Browse files
albertshauvravish
authored andcommitted
bump version and fix unit test
1 parent 89ec2cb commit b761cdc

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -161,8 +161,7 @@ public void testScalaProgram() throws Exception {
161161
Map<String, String> runtimeArgs = new HashMap<>(RuntimeArguments.addScope(Scope.DATASET, "text", inputArgs));
162162

163163
WorkflowManager workflowManager = appManager.getWorkflowManager(SmartWorkflow.NAME);
164-
workflowManager.start(runtimeArgs);
165-
workflowManager.waitForRun(ProgramRunStatus.COMPLETED, 5, TimeUnit.MINUTES);
164+
workflowManager.startAndWaitForRun(runtimeArgs, ProgramRunStatus.COMPLETED, 5, TimeUnit.MINUTES);
166165

167166
// Validate the result
168167
KeyValueTable kvTable = this.<KeyValueTable>getDataset("kvTable").get();

0 commit comments

Comments
 (0)