Skip to content

Commit 5e4c06f

Browse files
sryzaJoshRosen
authored andcommitted
SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable
Author: Sandy Ryza <[email protected]> Closes #3426 from sryza/sandy-spark-4567 and squashes the following commits: cb4b8d2 [Sandy Ryza] SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable
1 parent 30dca92 commit 5e4c06f

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

core/src/main/java/org/apache/spark/SparkJobInfo.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,15 @@
1717

1818
package org.apache.spark;
1919

20+
import java.io.Serializable;
21+
2022
/**
2123
* Exposes information about Spark Jobs.
2224
*
2325
* This interface is not designed to be implemented outside of Spark. We may add additional methods
2426
* which may break binary compatibility with outside implementations.
2527
*/
26-
public interface SparkJobInfo {
28+
public interface SparkJobInfo extends Serializable {
2729
int jobId();
2830
int[] stageIds();
2931
JobExecutionStatus status();

core/src/main/java/org/apache/spark/SparkStageInfo.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,13 +17,15 @@
1717

1818
package org.apache.spark;
1919

20+
import java.io.Serializable;
21+
2022
/**
2123
* Exposes information about Spark Stages.
2224
*
2325
* This interface is not designed to be implemented outside of Spark. We may add additional methods
2426
* which may break binary compatibility with outside implementations.
2527
*/
26-
public interface SparkStageInfo {
28+
public interface SparkStageInfo extends Serializable {
2729
int stageId();
2830
int currentAttemptId();
2931
long submissionTime();

0 commit comments

Comments
 (0)