Github user xuchuanyin commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2627#discussion_r210202221 --- Diff: datamap/mv/core/src/main/scala/org/apache/carbondata/mv/datamap/MVHelper.scala --- @@ -80,6 +81,16 @@ object MVHelper { dmProperties.foreach(t => tableProperties.put(t._1, t._2)) val selectTables = getTables(logicalPlan) + selectTables.map { selectTable => + val mainCarbonTable = CarbonEnv.getCarbonTableOption(selectTable.identifier.database, + selectTable.identifier.table)(sparkSession) + + if (!mainCarbonTable.isEmpty && mainCarbonTable.get.isStreamingSink ) { + throw new MalformedCarbonCommandException(s"Streaming table does not support creating " + --- End diff -- weird indentation here. You can start the statement in a new line to make the message in a complete line for better reading.
---