美文网首页
Spark LiveListenerBus

Spark LiveListenerBus

作者: clive0x | 来源:发表于2019-06-01 16:01 被阅读0次

    开启四个事件处理队列:

    private[scheduler] val SHARED_QUEUE = "shared"

      private[scheduler] val APP_STATUS_QUEUE = "appStatus"

      private[scheduler] val EXECUTOR_MANAGEMENT_QUEUE = "executorManagement"

      private[scheduler] val EVENT_LOG_QUEUE = "eventLog"

    每个队列单独一个线程处理。

    相关文章

      网友评论

          本文标题:Spark LiveListenerBus

          本文链接:https://www.haomeiwen.com/subject/ctdatctx.html