Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2609#discussion_r208126659
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/strategy/DDLStrategy.scala
---
@@ -257,20 +256,13 @@ class DDLStrategy(sparkSession: SparkSession) extends
SparkStrategy {
if CarbonEnv.getInstance(sparkSession).carbonMetastore
.tableExists(tableName)(sparkSession) => {
- // TODO remove this limiation after streaming table support
'preaggregate' DataMap
- // if the table has 'preaggregate' DataMap, it doesn't support
streaming now
val carbonTable =
CarbonEnv.getInstance(sparkSession).carbonMetastore
.lookupRelation(tableName)(sparkSession).asInstanceOf[CarbonRelation].carbonTable
if (carbonTable != null &&
!carbonTable.getTableInfo.isTransactionalTable) {
throw new MalformedCarbonCommandException(
"Unsupported operation on non transactional table")
}
- if (carbonTable != null && !carbonTable.canAllow(carbonTable,
TableOperation.STREAMING)) {
--- End diff --
After discussed with @jacklk, we are planning to block MV datamap on
streaming table and CARBONDATA-2835 was reported to solve this.
---
