Fix expectations in CombineTest
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a593e490 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a593e490 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a593e490 Branch: refs/heads/tez-runner Commit: a593e4908477e897f71a0847b6502fc5eef486ad Parents: 219b9ca Author: Kenneth Knowles <k...@apache.org> Authored: Mon Oct 16 16:45:46 2017 -0700 Committer: Kenneth Knowles <k...@apache.org> Committed: Mon Nov 13 15:03:21 2017 -0800 ---------------------------------------------------------------------- .../src/test/java/org/apache/beam/sdk/transforms/CombineTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a593e490/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CombineTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CombineTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CombineTest.java index 52fedc6..2b5ab5a 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CombineTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/CombineTest.java @@ -451,7 +451,7 @@ public class CombineTest implements Serializable { .apply(Window.<Integer>into(new GlobalWindows()) .triggering(Repeatedly.forever(AfterPane.elementCountAtLeast(1))) .accumulatingFiredPanes() - .withAllowedLateness(new Duration(0))) + .withAllowedLateness(new Duration(0), ClosingBehavior.FIRE_ALWAYS)) .apply(Sum.integersGlobally()) .apply(ParDo.of(new FormatPaneInfo()));