Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2495#discussion_r202222412
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/stream/CarbonCreateStreamCommand.scala
---
@@ -53,20 +52,22 @@ case class CarbonCreateStreamCommand(
override def processData(sparkSession: SparkSession): Seq[Row] = {
val df = sparkSession.sql(query)
var sourceTable: CarbonTable = null
+ var dataFrame: Option[DataFrame] = None
// find the streaming source table in the query
// and replace it with StreamingRelation
--- End diff --
please modify this comment to describe the updated code
---
