submit PR

Author: brkyvz

core/src/test/scala/org/apache/spark/deploy/SparkSubmitUtilsSuite.scala

@@ -58,7 +58,7 @@ class SparkSubmitUtilsSuite extends FunSuite with BeforeAndAfterAll {
   test("create repo resolvers") {
     val resolver1 = SparkSubmitUtils.createRepoResolvers(None)
     // should have central by default
-    assert(resolver1.getResolvers.size() === 1)
+    assert(resolver1.getResolvers.size() === 2)
     assert(resolver1.getResolvers.get(0).asInstanceOf[IBiblioResolver].getName === "central")
 
     val repos = "a/1,b/2,c/3"

python/pyspark/tests.py

@@ -1553,8 +1553,8 @@ def test_package_dependency_on_cluster(self):
             """)
         self.create_spark_package("a:mylib:0.1")
         proc = subprocess.Popen([self.sparkSubmit, "--packages", "a:mylib:0.1", "--repositories",
-                                 "file:" + self.programDir, "--master", "local-cluster[1,1,512]", script],
-                                stdout=subprocess.PIPE)
+                                 "file:" + self.programDir, "--master", 
+                                 "local-cluster[1,1,512]", script], stdout=subprocess.PIPE)
         out, err = proc.communicate()
         self.assertEqual(0, proc.returncode)
         self.assertIn("[2, 3, 4]", out)