Repository: incubator-carbondata Updated Branches: refs/heads/master d3abcd91b -> 060b455a8
fix jira CARBONDATA-975: remove unreasonable code Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/226c4f29 Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/226c4f29 Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/226c4f29 Branch: refs/heads/master Commit: 226c4f2958507de4f232c336af9f8c2414ec6c7c Parents: d3abcd9 Author: mayun <simafengyun1...@163.com> Authored: Mon Apr 24 14:24:51 2017 +0800 Committer: mayun <simafengyun1...@163.com> Committed: Mon Apr 24 14:24:51 2017 +0800 ---------------------------------------------------------------------- .../apache/spark/sql/execution/command/carbonTableSchema.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/226c4f29/integration/spark-common/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala ---------------------------------------------------------------------- diff --git a/integration/spark-common/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala b/integration/spark-common/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala index 5108df8..e03cbe5 100644 --- a/integration/spark-common/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala +++ b/integration/spark-common/src/main/scala/org/apache/spark/sql/execution/command/carbonTableSchema.scala @@ -266,7 +266,7 @@ class AlterTableColumnSchemaGenerator( columnSchema.setDataType(dataType) columnSchema.setColumnName(colName) if (alterTableModel.highCardinalityDims.contains(colName)) { - encoders.remove(encoders.remove(Encoding.DICTIONARY)) + encoders.remove(Encoding.DICTIONARY) } if (dataType == DataType.TIMESTAMP || dataType == DataType.DATE) { encoders.add(Encoding.DIRECT_DICTIONARY) @@ -331,7 +331,7 @@ class TableNewProcessor(cm: TableModel) { columnSchema.setColumnName(colName) val highCardinalityDims = cm.highcardinalitydims.getOrElse(Seq()) if (highCardinalityDims.contains(colName)) { - encoders.remove(encoders.remove(Encoding.DICTIONARY)) + encoders.remove(Encoding.DICTIONARY) } if (dataType == DataType.TIMESTAMP || dataType == DataType.DATE) { encoders.add(Encoding.DIRECT_DICTIONARY)
