You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mh...@apache.org on 2018/12/09 22:59:05 UTC
asterixdb-bad git commit: [NO ISSUE][BAD] Coordinated Change For
Merge Commit 'b6a70e19'
Repository: asterixdb-bad
Updated Branches:
refs/heads/master 64c2ad2ef -> ed3aff538
[NO ISSUE][BAD] Coordinated Change For Merge Commit 'b6a70e19'
Change-Id: I9d9d7b0dee6d831858fff9961c870fa72c734827
Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/ed3aff53
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/ed3aff53
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/ed3aff53
Branch: refs/heads/master
Commit: ed3aff538b0526692784ad700f389f50152dabda
Parents: 64c2ad2
Author: Murtadha Hubail <mu...@couchbase.com>
Authored: Sun Dec 9 21:32:38 2018 +0300
Committer: Murtadha Hubail <mu...@couchbase.com>
Committed: Sun Dec 9 21:32:38 2018 +0300
----------------------------------------------------------------------
.../java/org/apache/asterix/bad/lang/BADStatementExecutor.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/ed3aff53/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 1a5fc34..600abab 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
@@ -297,7 +297,7 @@ public class BADStatementExecutor extends QueryTranslator {
@Override
protected void handleDataverseDropStatement(MetadataProvider metadataProvider, Statement stmt,
- IHyracksClientConnection hcc) throws Exception {
+ IHyracksClientConnection hcc, IRequestParameters requestParameters) throws Exception {
MetadataTransactionContext mdTxnCtx = MetadataManager.INSTANCE.beginTransaction();
metadataProvider.setMetadataTxnContext(mdTxnCtx);
Identifier dvId = ((DataverseDropStatement) stmt).getDataverseName();
@@ -333,8 +333,6 @@ public class BADStatementExecutor extends QueryTranslator {
}
}
}
- 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;
@@ -360,7 +358,7 @@ public class BADStatementExecutor extends QueryTranslator {
drop.handle(hcc, this, requestParameters, tempMdProvider, 0, null);
}
MetadataManager.INSTANCE.commitTransaction(mdTxnCtx);
- super.handleDataverseDropStatement(metadataProvider, stmt, hcc);
+ super.handleDataverseDropStatement(metadataProvider, stmt, hcc, requestParameters);
}
}