You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2014/12/10 01:26:21 UTC
spark git commit: SPARK-4567. Make SparkJobInfo and SparkStageInfo
serializable
Repository: spark
Updated Branches:
refs/heads/master 30dca924d -> 5e4c06f8e
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
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 <sa...@cloudera.com>
Authored: Tue Dec 9 16:26:07 2014 -0800
Committer: Josh Rosen <jo...@databricks.com>
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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org