Make filterSystemEnvironment method protected

pashields · pashields · commit 539988ce1399 · 2015-09-03T08:28:37.000-04:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionClient.scala b/core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionClient.scala
@@ -419,7 +419,7 @@ private[spark] object RestSubmissionClient {
   /**
    * Filter non-spark environment variables from any environment.
    */
-  def filterSystemEnvironment(env: Map[String, String]): Map[String, String] = {
+  protected[rest] def filterSystemEnvironment(env: Map[String, String]): Map[String, String] = {
     env.filter { case (k, _) =>
       (k.startsWith("SPARK_") && k != "SPARK_ENV_LOADED") || k.startsWith("MESOS_")
     }

Original file line number	Diff line number	Diff line change
`@@ -419,7 +419,7 @@ private[spark] object RestSubmissionClient {`
`419`	`419`	`/**`
`420`	`420`	`* Filter non-spark environment variables from any environment.`
`421`	`421`	`*/`
`422`		`- def filterSystemEnvironment(env: Map[String, String]): Map[String, String] = {`
	`422`	`+ protected[rest] def filterSystemEnvironment(env: Map[String, String]): Map[String, String] = {`
`423`	`423`	`env.filter { case (k, _) =>`
`424`	`424`	`(k.startsWith("SPARK_") && k != "SPARK_ENV_LOADED") \|\| k.startsWith("MESOS_")`
`425`	`425`	`}`