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/05/23 02:03:07 UTC
beam git commit: Fix compile error from bad merge
Repository: beam
Updated Branches:
refs/heads/master a32bef96d -> 9da46fd05
Fix compile error from bad merge
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9da46fd0
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9da46fd0
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9da46fd0
Branch: refs/heads/master
Commit: 9da46fd053ef3e7538733d45cacad435c312e51b
Parents: a32bef9
Author: Kenneth Knowles <kl...@google.com>
Authored: Mon May 22 19:02:56 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon May 22 19:02:56 2017 -0700
----------------------------------------------------------------------
.../beam/runners/core/construction/WindowIntoTranslatorTest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/9da46fd0/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/WindowIntoTranslatorTest.java
----------------------------------------------------------------------
diff --git a/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/WindowIntoTranslatorTest.java b/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/WindowIntoTranslatorTest.java
index fbac565..eaefe2e 100644
--- a/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/WindowIntoTranslatorTest.java
+++ b/runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/WindowIntoTranslatorTest.java
@@ -84,7 +84,8 @@ public class WindowIntoTranslatorTest {
public void visitPrimitiveTransform(Node node) {
if (node.getTransform() instanceof Window.Assign) {
checkState(assign.get() == null);
- assign.set((AppliedPTransform<?, ?, Assign<?>>) node.toAppliedPTransform());
+ assign.set(
+ (AppliedPTransform<?, ?, Assign<?>>) node.toAppliedPTransform(getPipeline()));
}
}
});