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


---

Reply via email to