[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/92eed69f Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/92eed69f Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/92eed69f Branch: refs/heads/branch-1.4 Commit: 92eed69f7677696a81919149f644fa069fc2c775 Parents: d587005 Author: Sssan520 <[email protected]> Authored: Wed Jul 25 19:36:00 2018 +0800 Committer: ravipesala <[email protected]> Committed: Tue Jul 31 00:11:26 2018 +0530 ---------------------------------------------------------------------- .../execution/command/management/CarbonCleanFilesCommand.scala | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/carbondata/blob/92eed69f/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 =>
