[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 <[email protected]> Authored: Sat Mar 12 17:27:38 2016 +0200 Committer: Sela <[email protected]> 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) {
