update

Author: AngersZhuuuu

core/src/main/scala/org/apache/spark/api/java/JavaSparkContext.scala

@@ -546,8 +546,8 @@ class JavaSparkContext(val sc: SparkContext) extends Closeable {
   def broadcast[T](value: T): Broadcast[T] = sc.broadcast(value)(fakeClassTag)
 
   /** Shut down the SparkContext. */
-  def stop(exitCode: Int = 0): Unit = {
-    sc.stop(exitCode)
+  def stop(): Unit = {
+    sc.stop()
   }
 
   override def close(): Unit = stop()

core/src/test/java/test/org/apache/spark/JavaSparkContextSuite.java

@@ -42,12 +42,12 @@ public void javaSparkContext() throws IOException {
     String[] jars = new String[] {};
     java.util.Map<String, String> environment = new java.util.HashMap<>();
 
-    new JavaSparkContext(new SparkConf().setMaster("local").setAppName("name")).stop(0);
-    new JavaSparkContext("local", "name", new SparkConf()).stop(0);
-    new JavaSparkContext("local", "name").stop(0);
-    new JavaSparkContext("local", "name", "sparkHome", dummyJarFile).stop(0);
-    new JavaSparkContext("local", "name", "sparkHome", jars).stop(0);
-    new JavaSparkContext("local", "name", "sparkHome", jars, environment).stop(0);
+    new JavaSparkContext(new SparkConf().setMaster("local").setAppName("name")).stop();
+    new JavaSparkContext("local", "name", new SparkConf()).stop();
+    new JavaSparkContext("local", "name").stop();
+    new JavaSparkContext("local", "name", "sparkHome", dummyJarFile).stop();
+    new JavaSparkContext("local", "name", "sparkHome", jars).stop();
+    new JavaSparkContext("local", "name", "sparkHome", jars, environment).stop();
   }
 
   @Test