Repository: spark Updated Branches: refs/heads/master 30dca924d -> 5e4c06f8e
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 Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/5e4c06f8 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/5e4c06f8 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/5e4c06f8 Branch: refs/heads/master Commit: 5e4c06f8e54265a4024857f5978ec54c936aeea2 Parents: 30dca92 Author: Sandy Ryza <[email protected]> Authored: Tue Dec 9 16:26:07 2014 -0800 Committer: Josh Rosen <[email protected]> Committed: Tue Dec 9 16:26:07 2014 -0800 ---------------------------------------------------------------------- core/src/main/java/org/apache/spark/SparkJobInfo.java | 4 +++- core/src/main/java/org/apache/spark/SparkStageInfo.java | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/5e4c06f8/core/src/main/java/org/apache/spark/SparkJobInfo.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/spark/SparkJobInfo.java b/core/src/main/java/org/apache/spark/SparkJobInfo.java index 4e3c983..e31c440 100644 --- a/core/src/main/java/org/apache/spark/SparkJobInfo.java +++ b/core/src/main/java/org/apache/spark/SparkJobInfo.java @@ -17,13 +17,15 @@ package org.apache.spark; +import java.io.Serializable; + /** * Exposes information about Spark Jobs. * * This interface is not designed to be implemented outside of Spark. We may add additional methods * which may break binary compatibility with outside implementations. */ -public interface SparkJobInfo { +public interface SparkJobInfo extends Serializable { int jobId(); int[] stageIds(); JobExecutionStatus status(); http://git-wip-us.apache.org/repos/asf/spark/blob/5e4c06f8/core/src/main/java/org/apache/spark/SparkStageInfo.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/spark/SparkStageInfo.java b/core/src/main/java/org/apache/spark/SparkStageInfo.java index fd74321..b7d462a 100644 --- a/core/src/main/java/org/apache/spark/SparkStageInfo.java +++ b/core/src/main/java/org/apache/spark/SparkStageInfo.java @@ -17,13 +17,15 @@ package org.apache.spark; +import java.io.Serializable; + /** * Exposes information about Spark Stages. * * This interface is not designed to be implemented outside of Spark. We may add additional methods * which may break binary compatibility with outside implementations. */ -public interface SparkStageInfo { +public interface SparkStageInfo extends Serializable { int stageId(); int currentAttemptId(); long submissionTime(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
