Github user zzcclp commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2508#discussion_r202566105
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/streaming/StreamSinkFactory.scala
---
@@ -78,13 +78,13 @@ object StreamSinkFactory {
}
}
+
def createStreamTableSink(
sparkSession: SparkSession,
hadoopConf: Configuration,
carbonTable: CarbonTable,
parameters: Map[String, String]): Sink = {
--- End diff --
remove blank line---
