diff options
| author | Jacek Lewandowski <lewandowski.jacek@gmail.com> | 2015-07-21 09:53:33 -0700 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-07-21 09:53:33 -0700 |
| commit | 31954910d67c29874d2af22ee30590a7346a464c (patch) | |
| tree | 4264d50c14b4c5f0e176e1574b16e627fda84c20 /core/src/test/java | |
| parent | 9a4fd875b39b6a1ef7038823d1c49b0826110fbc (diff) | |
| download | spark-31954910d67c29874d2af22ee30590a7346a464c.tar.gz spark-31954910d67c29874d2af22ee30590a7346a464c.tar.bz2 spark-31954910d67c29874d2af22ee30590a7346a464c.zip | |
[SPARK-7171] Added a method to retrieve metrics sources in TaskContext
Author: Jacek Lewandowski <lewandowski.jacek@gmail.com>
Closes #5805 from jacek-lewandowski/SPARK-7171 and squashes the following commits:
ed20bda [Jacek Lewandowski] SPARK-7171: Added a method to retrieve metrics sources in TaskContext
Diffstat (limited to 'core/src/test/java')
| -rw-r--r-- | core/src/test/java/org/apache/spark/JavaAPISuite.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/java/org/apache/spark/JavaAPISuite.java b/core/src/test/java/org/apache/spark/JavaAPISuite.java index dfd86d3e51..1b04a3b1cf 100644 --- a/core/src/test/java/org/apache/spark/JavaAPISuite.java +++ b/core/src/test/java/org/apache/spark/JavaAPISuite.java @@ -1011,7 +1011,7 @@ public class JavaAPISuite implements Serializable { @Test public void iterator() { JavaRDD<Integer> rdd = sc.parallelize(Arrays.asList(1, 2, 3, 4, 5), 2); - TaskContext context = new TaskContextImpl(0, 0, 0L, 0, null, false, new TaskMetrics()); + TaskContext context = new TaskContextImpl(0, 0, 0L, 0, null, null, false, new TaskMetrics()); Assert.assertEquals(1, rdd.iterator(rdd.partitions().get(0), context).next().intValue()); } |