Github user QiangCai commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1564#discussion_r153036781
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/strategy/DDLStrategy.scala
---
@@ -156,11 +156,22 @@ class DDLStrategy(sparkSession: SparkSession) extends
SparkStrategy {
case AlterTableSetPropertiesCommand(tableName, properties, isView)
if CarbonEnv.getInstance(sparkSession).carbonMetastore
.tableExists(tableName)(sparkSession) => {
+ val property = properties.find(_._1.equalsIgnoreCase("streaming"))
+ if (property.isDefined) {
+ if (!property.get._2.trim.equalsIgnoreCase("true")) {
+ throw new MalformedCarbonCommandException(
+ "Unsupported alter table to disable streaming property")
--- End diff --
fixed
---
