beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [3/5] beam git commit: Fix expectations in CombineTest
Date Mon, 13 Nov 2017 23:32:49 GMT
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 <kenn@apache.org>
Authored: Mon Oct 16 16:45:46 2017 -0700
Committer: Kenneth Knowles <kenn@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()));
 


Mime
View raw message