Hi, I have a spark streaming application that runs locally with two receivers, some code snippet is as follows:
conf.setMaster("local[4]") //RPC Log Streaming val rpcStream = KafkaUtils.createStream[String, String, StringDecoder, StringDecoder](ssc, consumerParams, topicRPC, StorageLevel.MEMORY_ONLY) RPCLogStreamProcessor.process(rpcStream, taskConfBroadcast) //HTTP Log Streaming val httpStream = KafkaUtils.createStream[String, String, StringDecoder, StringDecoder](ssc, consumerParams, topicHTTP, StorageLevel.MEMORY_ONLY) HttpLogStreamProcessor.process(httpStream, taskConfBroadcast) There is a log information showing on the console in red color [Stage 0:> (0 + 2) / 2] It appears, then disappear, and then appear, disappear... For the above code, if I only have rpc streaming and comment the httpStream, then it disappear. I don't know how it occurs and how to suppress it bit1...@163.com