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/11/13 23:32:49 UTC
[3/5] beam git commit: Fix expectations in CombineTest
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/master
Commit: a593e4908477e897f71a0847b6502fc5eef486ad
Parents: 219b9ca
Author: Kenneth Knowles <ke...@apache.org>
Authored: Mon Oct 16 16:45:46 2017 -0700
Committer: Kenneth Knowles <ke...@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()));