You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/08/08 16:17:27 UTC
beam git commit: Fix compile break
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 <kl...@google.com>
Authored: Tue Aug 8 09:12:29 2017 -0700
Committer: Kenneth Knowles <kl...@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() {