You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2016/03/15 19:47:59 UTC
[02/23] incubator-beam git commit: [BEAM-11] extractOutput() should
not return null
[BEAM-11] extractOutput() should not return null
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7e9aab06
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7e9aab06
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7e9aab06
Branch: refs/heads/master
Commit: 7e9aab0651a56772ca585cb34ebfed76497c0e79
Parents: c5c7df6
Author: Sela <an...@paypal.com>
Authored: Sat Mar 12 17:27:38 2016 +0200
Committer: Sela <an...@paypal.com>
Committed: Tue Mar 15 20:38:26 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/beam/runners/spark/CombineGloballyTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/7e9aab06/runners/spark/src/test/java/org/apache/beam/runners/spark/CombineGloballyTest.java
----------------------------------------------------------------------
diff --git a/runners/spark/src/test/java/org/apache/beam/runners/spark/CombineGloballyTest.java b/runners/spark/src/test/java/org/apache/beam/runners/spark/CombineGloballyTest.java
index e36babe..49e68f5 100644
--- a/runners/spark/src/test/java/org/apache/beam/runners/spark/CombineGloballyTest.java
+++ b/runners/spark/src/test/java/org/apache/beam/runners/spark/CombineGloballyTest.java
@@ -73,7 +73,7 @@ public class CombineGloballyTest {
@Override
public String extractOutput(StringBuilder accumulator) {
- return accumulator.toString();
+ return accumulator != null ? accumulator.toString(): "";
}
private static StringBuilder combine(StringBuilder accum, String datum) {