From d5ef650f9d29bf8d05ea5912a2b3704108fc73ec Mon Sep 17 00:00:00 2001 From: Abdullah Alamoudi Date: Sun, 27 Aug 2017 17:14:59 -0700 Subject: [PATCH] Update AsterixDB and Hyracks versions Change-Id: I2cca9cbf893465e358b220bc6e2a3af2bd631575 --- asterix-bad/pom.xml | 4 ++-- .../asterix/bad/lang/statement/ChannelSubscribeStatement.java | 4 ++-- .../asterix/bad/lang/statement/CreateChannelStatement.java | 2 +- .../asterix/bad/lang/statement/CreateProcedureStatement.java | 2 +- asterix-opt-bom/pom.xml | 2 +- pom.xml | 2 +- 6 files changed, 8 insertions(+), 8 deletions(-) diff --git a/asterix-bad/pom.xml b/asterix-bad/pom.xml index 90a0b89..8738162 100644 --- a/asterix-bad/pom.xml +++ b/asterix-bad/pom.xml @@ -25,8 +25,8 @@ asterix-bad - 0.9.2-SNAPSHOT - 0.3.2-SNAPSHOT + 0.9.3-SNAPSHOT + 0.3.3-SNAPSHOT diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java index 5460d3f..c5f6319 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ChannelSubscribeStatement.java @@ -207,13 +207,13 @@ public void handle(IStatementExecutor statementExecutor, MetadataProvider metada InsertStatement insert = new InsertStatement(new Identifier(dataverse), new Identifier(subscriptionsDatasetName), subscriptionTuple, varCounter, resultVar, accessor); ((QueryTranslator) statementExecutor).handleInsertUpsertStatement(tempMdProvider, insert, hcc, hdc, - resultDelivery, null, stats, false, null, null); + resultDelivery, null, stats, false, null); } else { //To update an existing subscription UpsertStatement upsert = new UpsertStatement(new Identifier(dataverse), new Identifier(subscriptionsDatasetName), subscriptionTuple, varCounter, null, null); ((QueryTranslator) statementExecutor).handleInsertUpsertStatement(tempMdProvider, upsert, hcc, hdc, - resultDelivery, null, stats, false, null, null); + resultDelivery, null, stats, false, null); } MetadataManager.INSTANCE.commitTransaction(mdTxnCtx); diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java index c6a72b6..8c0a146 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java @@ -234,7 +234,7 @@ private JobSpecification createChannelJob(IStatementExecutor statementExecutor, metadataProvider.getConfig().put(ss.getPropName(), ss.getPropValue()); return ((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider, fStatements.get(1), - hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null, null); + hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null); } private void setupExecutorJob(EntityId entityId, JobSpecification channeljobSpec, IHyracksClientConnection hcc, diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java index e10fea9..35eae6c 100644 --- a/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java +++ b/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java @@ -171,7 +171,7 @@ private Pair createProcedureJob(String body, if (fStatements.get(0).getKind() == Statement.Kind.INSERT) { return new Pair<>( ((QueryTranslator) statementExecutor).handleInsertUpsertStatement(metadataProvider, - fStatements.get(0), hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null, null), + fStatements.get(0), hcc, hdc, ResultDelivery.ASYNC, null, stats, true, null), PrecompiledType.INSERT); } else if (fStatements.get(0).getKind() == Statement.Kind.QUERY) { Pair pair = diff --git a/asterix-opt-bom/pom.xml b/asterix-opt-bom/pom.xml index 8d3fd67..89d8b9e 100644 --- a/asterix-opt-bom/pom.xml +++ b/asterix-opt-bom/pom.xml @@ -30,7 +30,7 @@ org.apache.asterix asterix-opt-bom - 0.9.2-SNAPSHOT + 0.9.3-SNAPSHOT pom asterix-opt-bom BAD Extension to AsterixDB diff --git a/pom.xml b/pom.xml index 8804649..d1f8c85 100644 --- a/pom.xml +++ b/pom.xml @@ -25,7 +25,7 @@ org.apache.asterix apache-asterixdb - 0.9.2-SNAPSHOT + 0.9.3-SNAPSHOT asterix-bad