From 939d790f76c4874b8d42eca791acfe426d0d20a4 Mon Sep 17 00:00:00 2001 From: Murtadha Hubail Date: Tue, 21 Nov 2017 20:31:02 +0300 Subject: [PATCH] Coordinated Change For Removing Temporary Datasets Change-Id: I76b6bccaa76adabe17eb2fb45825607bef573b12 --- .../asterix/bad/lang/statement/CreateChannelStatement.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 @@ private void createDatasets(IStatementExecutor statementExecutor, Identifier sub List 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(), new HashMap(), DatasetType.INTERNAL, idd, true); @@ -192,7 +192,7 @@ private void createDatasets(IStatementExecutor statementExecutor, Identifier sub 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(), new HashMap(), DatasetType.INTERNAL, idd, true);