Repository: beam Updated Branches: refs/heads/master 89236e3b5 -> 2fa4fdecd
Fix compile break Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2fa4fdec Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2fa4fdec Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2fa4fdec Branch: refs/heads/master Commit: 2fa4fdecd8ef06534e369e527b15ae8193823c8b Parents: 89236e3 Author: Kenneth Knowles <k...@google.com> Authored: Tue Aug 8 09:12:29 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Aug 8 09:12:29 2017 -0700 ---------------------------------------------------------------------- .../runners/gearpump/translators/CreateStreamingGearpumpView.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/2fa4fdec/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java ---------------------------------------------------------------------- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java index 60577b3..3ebe5c8 100644 --- a/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java +++ b/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/CreateStreamingGearpumpView.java @@ -124,8 +124,7 @@ class CreateStreamingGearpumpView<ElemT, ViewT> @Override public PCollection<List<ElemT>> expand(PCollection<List<ElemT>> input) { return PCollection.<List<ElemT>>createPrimitiveOutputInternal( - input.getPipeline(), input.getWindowingStrategy(), input.isBounded()) - .setCoder(input.getCoder()); + input.getPipeline(), input.getWindowingStrategy(), input.isBounded(), input.getCoder()); } public PCollectionView<ViewT> getView() {
