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();