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 <[email protected]> Authored: Mon May 22 19:02:56 2017 -0700 Committer: Kenneth Knowles <[email protected]> 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())); } } });
