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 <[email protected]> Authored: Sun Dec 9 21:32:38 2018 +0300 Committer: Murtadha Hubail <[email protected]> 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); } }
