Github user rahulforallp commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2008#discussion_r171465697 --- Diff: streaming/src/main/scala/org/apache/carbondata/streaming/StreamHandoffRDD.scala --- @@ -277,15 +277,21 @@ object StreamHandoffRDD { */ def startStreamingHandoffThread( carbonLoadModel: CarbonLoadModel, - sparkSession: SparkSession + sparkSession: SparkSession, + isDDL: Boolean ): Unit = { // start a new thread to execute streaming segment handoff val handoffThread = new Thread() { --- End diff -- Done
---