Github user felixcheung commented on a diff in the pull request: https://github.com/apache/spark/pull/21996#discussion_r207717051 --- Diff: core/src/main/scala/org/apache/spark/deploy/SparkSubmit.scala --- @@ -98,17 +98,24 @@ private[spark] class SparkSubmit extends Logging { * Kill an existing submission using the REST protocol. Standalone and Mesos cluster mode only. */ private def kill(args: SparkSubmitArguments): Unit = { - new RestSubmissionClient(args.master) - .killSubmission(args.submissionToKill) + createRestSubmissionClient(args).killSubmission(args.submissionToKill) } /** * Request the status of an existing submission using the REST protocol. * Standalone and Mesos cluster mode only. */ private def requestStatus(args: SparkSubmitArguments): Unit = { - new RestSubmissionClient(args.master) - .requestSubmissionStatus(args.submissionToRequestStatusFor) + createRestSubmissionClient(args).requestSubmissionStatus(args.submissionToRequestStatusFor) + } + + /** + * Creates RestSubmissionClient with overridden logInfo() + */ + private def createRestSubmissionClient(args: SparkSubmitArguments): RestSubmissionClient = { + new RestSubmissionClient(args.master) { + override protected def logInfo(msg: => String): Unit = printMessage(msg) --- End diff -- this is not necessarily always the case - user can config log level easily?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org