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"
---
