scala promise 中netty channel 连接断开

gistfile1.txt

  val promise = Promise[ExecResult]()
      //  stop spark cluster
      SparkUtil.stop(promise)

      log.info("=========stopping spark cluster==========" + msg)
      val f = promise.future
      f onComplete {
        case Success(x) =>
          log.info("===================2222 " + x)
        case Failure(x) =>
          log.error("exec stop spark fail, retry, $msg")
      }