Coordinated change to redeploy job specs
Change-Id: I9baa1cd172d7ed8605b8eccbfe838c85f377f9e4
diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/BADJobService.java b/asterix-bad/src/main/java/org/apache/asterix/bad/BADJobService.java
index e326ce6..e587072 100644
--- a/asterix-bad/src/main/java/org/apache/asterix/bad/BADJobService.java
+++ b/asterix-bad/src/main/java/org/apache/asterix/bad/BADJobService.java
@@ -230,7 +230,7 @@
jobSpec = compileProcedureJob(badStatementExecutor, metadataProvider, hcc, hdc, stats, fStatements.get(1));
}
- hcc.upsertDeployedJobSpec(listener.getDeployedJobSpecId(), jobSpec);
+ hcc.redeployJobSpec(listener.getDeployedJobSpecId(), jobSpec);
listener.resume();