beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amits...@apache.org
Subject [07/50] [abbrv] incubator-beam git commit: Set the RDD's name from the PValue's name, to help diagnosis.
Date Thu, 10 Mar 2016 20:58:32 GMT
Set the RDD's name from the PValue's name, to help diagnosis.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5069eedb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5069eedb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5069eedb

Branch: refs/heads/master
Commit: 5069eedb6d3faa6560a79c82f2d091ff4e2becc0
Parents: 78d6614
Author: Tom White <tom@cloudera.com>
Authored: Tue Jun 30 09:28:40 2015 +0100
Committer: Tom White <tom@cloudera.com>
Committed: Thu Mar 10 11:15:14 2016 +0000

----------------------------------------------------------------------
 .../java/com/cloudera/dataflow/spark/EvaluationContext.java     | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/5069eedb/runners/spark/src/main/java/com/cloudera/dataflow/spark/EvaluationContext.java
----------------------------------------------------------------------
diff --git a/runners/spark/src/main/java/com/cloudera/dataflow/spark/EvaluationContext.java
b/runners/spark/src/main/java/com/cloudera/dataflow/spark/EvaluationContext.java
index 5337264..7906775 100644
--- a/runners/spark/src/main/java/com/cloudera/dataflow/spark/EvaluationContext.java
+++ b/runners/spark/src/main/java/com/cloudera/dataflow/spark/EvaluationContext.java
@@ -118,6 +118,11 @@ public class EvaluationContext implements EvaluationResult {
   }
 
   void setRDD(PValue pvalue, JavaRDDLike<?, ?> rdd) {
+    try {
+      rdd.rdd().setName(pvalue.getName());
+    } catch (IllegalStateException e) {
+      // name not set, ignore
+    }
     rdds.put(pvalue, rdd);
     leafRdds.add(rdd);
   }


Mime
View raw message