aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSandy Ryza <sandy@cloudera.com>2014-12-09 16:26:07 -0800
committerJosh Rosen <joshrosen@databricks.com>2014-12-09 16:26:28 -0800
commit51da2c557b98aec8309db01ecf8dd0f39c494d28 (patch)
treea234fce98170109935e179703f4017f6f827f713
parent5a3a3cc1739e4d5004bc7117bd6afadf3142ec9b (diff)
downloadspark-51da2c557b98aec8309db01ecf8dd0f39c494d28.tar.gz
spark-51da2c557b98aec8309db01ecf8dd0f39c494d28.tar.bz2
spark-51da2c557b98aec8309db01ecf8dd0f39c494d28.zip
SPARK-4567. Make SparkJobInfo and SparkStageInfo serializable
Author: Sandy Ryza <sandy@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 <joshrosen@databricks.com>
-rw-r--r--core/src/main/java/org/apache/spark/SparkJobInfo.java4
-rw-r--r--core/src/main/java/org/apache/spark/SparkStageInfo.java4
2 files changed, 6 insertions, 2 deletions
diff --git a/core/src/main/java/org/apache/spark/SparkJobInfo.java b/core/src/main/java/org/apache/spark/SparkJobInfo.java
index 4e3c983b11..e31c440163 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();
diff --git a/core/src/main/java/org/apache/spark/SparkStageInfo.java b/core/src/main/java/org/apache/spark/SparkStageInfo.java
index fd74321093..b7d462abd7 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();