You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2017/04/05 07:47:51 UTC
[1/2] incubator-carbondata git commit: Issue :
https://issues.apache.org/jira/browse/CARBONDATA-849
Repository: incubator-carbondata
Updated Branches:
refs/heads/master c62b29979 -> bd044c208
Issue : https://issues.apache.org/jira/browse/CARBONDATA-849
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/8245e5db
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/8245e5db
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/8245e5db
Branch: refs/heads/master
Commit: 8245e5dbc324e1998fc64e0061018695a49bc088
Parents: c62b299
Author: ravikiran <ra...@gmail.com>
Authored: Tue Apr 4 15:13:25 2017 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Wed Apr 5 13:16:59 2017 +0530
----------------------------------------------------------------------
.../apache/spark/sql/execution/command/carbonTableSchema.scala | 2 +-
.../org/apache/spark/sql/execution/command/DDLStrategy.scala | 3 ++-
.../scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala | 3 +++
3 files changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/8245e5db/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 3346743..6c44264 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
@@ -104,7 +104,7 @@ case class AlterTableModel(dbName: Option[String],
segmentUpdateStatusManager: Option[SegmentUpdateStatusManager],
compactionType: String,
factTimeStamp: Option[Long],
- alterSql: String)
+ var alterSql: String)
case class UpdateTableModel(isUpdate: Boolean,
updatedTimeStamp: Long,
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/8245e5db/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/DDLStrategy.scala
----------------------------------------------------------------------
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/DDLStrategy.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/DDLStrategy.scala
index fb15d6d..2916a9f 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/DDLStrategy.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/DDLStrategy.scala
@@ -72,7 +72,8 @@ class DDLStrategy(sparkSession: SparkSession) extends SparkStrategy {
"Unsupported alter operation on carbon table")
}
} else {
- throw new MalformedCarbonCommandException("Unsupported alter operation on hive table")
+ throw new MalformedCarbonCommandException(
+ "Operation not allowed : " + altertablemodel.alterSql)
}
case dataTypeChange@AlterTableDataTypeChange(alterTableChangeDataTypeModel) =>
val isCarbonTable = CarbonEnv.get.carbonMetastore
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/8245e5db/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala
----------------------------------------------------------------------
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala
index dbc3124..695f5fc 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala
@@ -43,6 +43,9 @@ class CarbonSpark2SqlParser extends CarbonDDLSqlParser {
case x: LoadTable =>
x.inputSqlString = input
x
+ case x: AlterTableCompaction =>
+ x.alterTableModel.alterSql = input
+ x
case logicalPlan => logicalPlan
}
case failureOrError =>
[2/2] incubator-carbondata git commit: [CARBONDATA-849] Correcting
the error message for alter table as per HIVE message for non existing table.
This closes #725
Posted by ra...@apache.org.
[CARBONDATA-849] Correcting the error message for alter table as per HIVE message for non existing table. This closes #725
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/bd044c20
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/bd044c20
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/bd044c20
Branch: refs/heads/master
Commit: bd044c20895e338884ceeb6ba4bdd5fb15649201
Parents: c62b299 8245e5d
Author: ravipesala <ra...@gmail.com>
Authored: Wed Apr 5 13:17:31 2017 +0530
Committer: ravipesala <ra...@gmail.com>
Committed: Wed Apr 5 13:17:31 2017 +0530
----------------------------------------------------------------------
.../apache/spark/sql/execution/command/carbonTableSchema.scala | 2 +-
.../org/apache/spark/sql/execution/command/DDLStrategy.scala | 3 ++-
.../scala/org/apache/spark/sql/parser/CarbonSpark2SqlParser.scala | 3 +++
3 files changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------