Repository: asterixdb-bad Updated Branches: refs/heads/master 51819b77a -> 9d0499973 refs/heads/resultsFinalVersion 0cf5a3ee2 -> f08062252
[NO ISSUE][BAD] Coordinated Change for Multi-Statement Change-Id: I94acfecbf5aaa21ab103173dd2a8ab89080461e0 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/563520ad Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/563520ad Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/563520ad Branch: refs/heads/resultsFinalVersion Commit: 563520ad136c27f8b9a27548e2a7caf5164db918 Parents: 105ee6d Author: Murtadha Hubail <[email protected]> Authored: Fri Jul 6 18:10:01 2018 +0300 Committer: Murtadha Hubail <[email protected]> Committed: Fri Jul 6 18:10:01 2018 +0300 ---------------------------------------------------------------------- .../java/org/apache/asterix/bad/lang/BADStatementExecutor.java | 3 ++- .../apache/asterix/bad/recovery/BADGlobalRecoveryManager.java | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/563520ad/asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java index 3ea2c0d..b95ca11 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java @@ -334,7 +334,8 @@ public class BADStatementExecutor extends QueryTranslator { } } } - final IRequestParameters requestParameters = new RequestParameters(null, null, null, null, null, null, null); + final IRequestParameters requestParameters = + new RequestParameters(null, null, null, null, null, null, null, true); for (Channel channel : channels) { if (!channel.getChannelId().getDataverse().equals(dvId.getValue())) { continue; http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/563520ad/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java ---------------------------------------------------------------------- diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java b/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java index 89d940e..f358986 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java @@ -122,7 +122,7 @@ public class BADGlobalRecoveryManager extends GlobalRecoveryManager { listener.suspend(); activeEventHandler.registerListener(listener); BADJobService.redeployJobSpec(entityId, channel.getChannelBody(), metadataProvider, badStatementExecutor, - hcc, new RequestParameters(null, null, null, null, null, null, null), true); + hcc, new RequestParameters(null, null, null, null, null, null, null, true), true); ScheduledExecutorService ses = BADJobService.startRepetitiveDeployedJobSpec(listener.getDeployedJobSpecId(), hcc, @@ -149,7 +149,7 @@ public class BADGlobalRecoveryManager extends GlobalRecoveryManager { new HyracksDataset(hcc, appCtx.getCompilerProperties().getFrameSize(), ResultReader.NUM_READERS), new ResultProperties(IStatementExecutor.ResultDelivery.IMMEDIATE), - new IStatementExecutor.Stats(), null, null, null, null), + new IStatementExecutor.Stats(), null, null, null, null, true), true); metadataProvider.getLocks().unlock(); //Log that the procedure stopped by cluster restart. Procedure is available again now.
