Repository: asterixdb-bad Updated Branches: refs/heads/master 8b53ce556 -> 939d790f7
Coordinated Change For Removing Temporary Datasets Change-Id: I76b6bccaa76adabe17eb2fb45825607bef573b12 Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/939d790f Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/939d790f Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/939d790f Branch: refs/heads/master Commit: 939d790f76c4874b8d42eca791acfe426d0d20a4 Parents: 8b53ce5 Author: Murtadha Hubail <[email protected]> Authored: Tue Nov 21 20:31:02 2017 +0300 Committer: Murtadha Hubail <[email protected]> Committed: Tue Nov 21 20:31:02 2017 +0300 ---------------------------------------------------------------------- .../asterix/bad/lang/statement/CreateChannelStatement.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/939d790f/asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java ---------------------------------------------------------------------- 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 0898eec..2a2ae54 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 @@ -182,7 +182,7 @@ public class CreateChannelStatement implements IExtensionStatement { List<String> fieldNames = new ArrayList<>(); fieldNames.add(BADConstants.SubscriptionId); partitionFields.add(fieldNames); - IDatasetDetailsDecl idd = new InternalDetailsDecl(partitionFields, keyIndicators, true, null, false); + IDatasetDetailsDecl idd = new InternalDetailsDecl(partitionFields, keyIndicators, true, null); DatasetDecl createSubscriptionsDataset = new DatasetDecl(new Identifier(dataverse), subscriptionsName, new Identifier(BADConstants.BAD_DATAVERSE_NAME), subscriptionsTypeName, null, null, null, null, new HashMap<String, String>(), new HashMap<String, String>(), DatasetType.INTERNAL, idd, true); @@ -192,7 +192,7 @@ public class CreateChannelStatement implements IExtensionStatement { fieldNames = new ArrayList<>(); fieldNames.add(BADConstants.ResultId); partitionFields.add(fieldNames); - idd = new InternalDetailsDecl(partitionFields, keyIndicators, true, null, false); + idd = new InternalDetailsDecl(partitionFields, keyIndicators, true, null); DatasetDecl createResultsDataset = new DatasetDecl(new Identifier(dataverse), resultsName, new Identifier(BADConstants.BAD_DATAVERSE_NAME), resultsTypeName, null, null, null, null, new HashMap<String, String>(), new HashMap<String, String>(), DatasetType.INTERNAL, idd, true);
