Repository: spark Updated Branches: refs/heads/branch-1.2 5a3a3cc17 -> 51da2c557
SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable Author: Sandy Ryza <sa...@cloudera.com> Closes #3426 from sryza/sandy-spark-4567 and squashes the following commits: cb4b8d2 [Sandy Ryza] SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable (cherry picked from commit 5e4c06f8e54265a4024857f5978ec54c936aeea2) Signed-off-by: Josh Rosen <joshro...@databricks.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/51da2c55 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/51da2c55 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/51da2c55 Branch: refs/heads/branch-1.2 Commit: 51da2c557b98aec8309db01ecf8dd0f39c494d28 Parents: 5a3a3cc Author: Sandy Ryza <sa...@cloudera.com> Authored: Tue Dec 9 16:26:07 2014 -0800 Committer: Josh Rosen <joshro...@databricks.com> Committed: Tue Dec 9 16:26:28 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/51da2c55/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/51da2c55/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: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
