Use empty SideInputReader, fixes NPE in SimpleDoFnRunnerTest
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b78aa669 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b78aa669 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b78aa669 Branch: refs/heads/gearpump-runner Commit: b78aa669831154f82266eb12ab795442c02f8977 Parents: 3b4c7d1 Author: Kenneth Knowles <k...@google.com> Authored: Fri Dec 16 20:57:06 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Fri Dec 16 20:57:06 2016 -0800 ---------------------------------------------------------------------- .../apache/beam/runners/core/SimpleDoFnRunnerTest.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b78aa669/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java ---------------------------------------------------------------------- diff --git a/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java b/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java index 837a162..ec5d375 100644 --- a/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java +++ b/runners/core-java/src/test/java/org/apache/beam/runners/core/SimpleDoFnRunnerTest.java @@ -33,6 +33,7 @@ import org.apache.beam.sdk.transforms.windowing.GlobalWindow; import org.apache.beam.sdk.transforms.windowing.GlobalWindows; import org.apache.beam.sdk.transforms.windowing.WindowFn; import org.apache.beam.sdk.util.BaseExecutionContext.StepContext; +import org.apache.beam.sdk.util.NullSideInputReader; import org.apache.beam.sdk.util.TimeDomain; import org.apache.beam.sdk.util.Timer; import org.apache.beam.sdk.util.TimerInternals; @@ -77,7 +78,7 @@ public class SimpleDoFnRunnerTest { new SimpleDoFnRunner<>( null, fn, - null, + NullSideInputReader.empty(), null, null, Collections.<TupleTag<?>>emptyList(), @@ -98,7 +99,7 @@ public class SimpleDoFnRunnerTest { new SimpleDoFnRunner<>( null, fn, - null, + NullSideInputReader.empty(), null, null, Collections.<TupleTag<?>>emptyList(), @@ -129,7 +130,7 @@ public class SimpleDoFnRunnerTest { new SimpleDoFnRunner<>( null, fn, - null, + NullSideInputReader.empty(), null, null, Collections.<TupleTag<?>>emptyList(), @@ -158,7 +159,7 @@ public class SimpleDoFnRunnerTest { new SimpleDoFnRunner<>( null, fn, - null, + NullSideInputReader.empty(), null, null, Collections.<TupleTag<?>>emptyList(), @@ -179,7 +180,7 @@ public class SimpleDoFnRunnerTest { new SimpleDoFnRunner<>( null, fn, - null, + NullSideInputReader.empty(), null, null, Collections.<TupleTag<?>>emptyList(), @@ -206,7 +207,7 @@ public class SimpleDoFnRunnerTest { new SimpleDoFnRunner<>( null, fn, - null, + NullSideInputReader.empty(), null, null, Collections.<TupleTag<?>>emptyList(),