Repository: carbondata Updated Branches: refs/heads/external-format ccf64ce5a -> 12ab57992 (forced update)
[CARBONDATA-2782]delete dead code in class 'CarbonCleanFilesCommand' The variables(dmsãindexDms) in function processMetadata are nerver used. This closes #2557 Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/c79fc90d Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/c79fc90d Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/c79fc90d Branch: refs/heads/external-format Commit: c79fc90d5d9804d65aea8d363f2249b12696aef0 Parents: d62fe9e Author: Sssan520 <liangap2...@aliyun.com> Authored: Wed Jul 25 19:36:00 2018 +0800 Committer: Jacky Li <jacky.li...@qq.com> Committed: Fri Jul 27 10:47:24 2018 +0800 ---------------------------------------------------------------------- .../execution/command/management/CarbonCleanFilesCommand.scala | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/c79fc90d/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonCleanFilesCommand.scala ---------------------------------------------------------------------- diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonCleanFilesCommand.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonCleanFilesCommand.scala index 9d0f149..e561a5a 100644 --- a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonCleanFilesCommand.scala +++ b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonCleanFilesCommand.scala @@ -58,10 +58,6 @@ case class CarbonCleanFilesCommand( override def processMetadata(sparkSession: SparkSession): Seq[Row] = { carbonTable = CarbonEnv.getCarbonTable(databaseNameOp, tableName.get)(sparkSession) - val dms = carbonTable.getTableInfo.getDataMapSchemaList.asScala.map(_.getDataMapName) - val indexDms = DataMapStoreManager.getInstance.getAllDataMap(carbonTable).asScala - .filter(_.getDataMapSchema.isIndexDataMap) - if (carbonTable.hasAggregationDataMap) { cleanFileCommands = carbonTable.getTableInfo.getDataMapSchemaList.asScala.map { dataMapSchema =>
