Github user xuchuanyin commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2239#discussion_r184842350 --- Diff: store/search/src/main/scala/org/apache/spark/rpc/Master.scala --- @@ -64,13 +64,29 @@ class Master(sparkConf: SparkConf, port: Int) { private val scheduler: Scheduler = new Scheduler + /** + * flag is the master status, default value is false, which means master not start now. + * if it is true, then search mode master finished start. + */ + private var flag: Boolean = false + def this(sparkConf: SparkConf) = { this(sparkConf, CarbonProperties.getSearchMasterPort) } + /** + * get the status flag info + * + * @return whether master started + */ + def isStarted(): Boolean = { + this.flag + } + /** start service and listen on port passed in constructor */ def startService(): Unit = { if (rpcEnv == null) { + LOG.info("Start search mode master thread") --- End diff -- extra blanks found in"mode master"
---