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

Posted to issues@carbondata.apache.org by jackylk <gi...@git.apache.org> on 2018/05/03 01:09:58 UTC

[GitHub] carbondata pull request #2239: [CARBONDATA-2408] Fix search mode master Sasl...

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

    https://github.com/apache/carbondata/pull/2239#discussion_r185679917
  
    --- Diff: integration/spark2/src/main/scala/org/apache/carbondata/store/SparkCarbonStore.scala ---
    @@ -110,8 +110,16 @@ class SparkCarbonStore extends MetaCachedCarbonStore {
       }
     
       def startSearchMode(): Unit = {
    +    LOG.info("Starting search mode master")
         master = new Master(session.sparkContext.getConf)
         master.startService()
    +    var count = 0
    +    while (master.isStarted().compareAndSet(false, false) && count < 5000) {
    +      LOG.info(s"Waiting search mode master to start, retrying $count times")
    +      Thread.sleep(10)
    +      count = count + 1;
    +    }
    +    LOG.info("Search mode master started")
    --- End diff --
    
    Need one more if check, if (count == 5000), should throw exception because it is failed to start master


---