[beam] branch master updated: Loosen Nexmark streaming pipeline finish condition

[pabloem]

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 5eeb633  Loosen Nexmark streaming pipeline finish condition
     new 3d9d66e  Merge pull request #12281 from y1chi/nexmark_count
5eeb633 is described below

commit 5eeb633edd0da1e41becedd222b43b75e8b35fab
Author: Yichi Zhang <zyi...@google.com>
AuthorDate: Thu Jul 16 11:45:39 2020 -0700

    Loosen Nexmark streaming pipeline finish condition
---
 .../src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
 
b/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
index 619a517..c93eced 100644
--- 
a/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
+++ 
b/sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
@@ -475,7 +475,7 @@ public class NexmarkLauncher<OptionT extends 
NexmarkOptions> {
           cancelJob = true;
         } else if (configuration.debug
             && configuration.numEvents > 0
-            && currPerf.numEvents == configuration.numEvents
+            && currPerf.numEvents >= configuration.numEvents
             && currPerf.numResults >= 0
             && quietFor.isLongerThan(DONE_DELAY)) {
           NexmarkUtils.console("streaming query appears to have finished 
waiting for completion.");