You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@carbondata.apache.org by QiangCai <gi...@git.apache.org> on 2018/03/01 02:32:08 UTC

[GitHub] carbondata pull request #2008: [CARBONDATA-2211] in case of DDL HndOff shoul...

Github user QiangCai commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2008#discussion_r171448904
  
    --- 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 --
    
    move this code to the inside of the if statement


---