[beam] branch master updated: Bump up advanceProcessingTime duration in ParDoTest

[goenka]

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

goenka 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 37e914b  Bump up advanceProcessingTime duration in ParDoTest
     new ead6971  Merge pull request #12608 from y1chi/flaky_test
37e914b is described below

commit 37e914b88a276f440f98e73955d4111168b197a6
Author: Yichi Zhang <zyi...@google.com>
AuthorDate: Mon Aug 17 18:01:08 2020 -0700

    Bump up advanceProcessingTime duration in ParDoTest
---
 .../test/java/org/apache/beam/sdk/transforms/ParDoTest.java    | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
index 6d365b9..e7cd5bb 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java
@@ -4024,8 +4024,9 @@ public class ParDoTest implements Serializable {
           TestStream.create(KvCoder.of(StringUtf8Coder.of(), VarIntCoder.of()))
               .addElements(KV.of("hello", 37))
               .advanceProcessingTime(
-                  Duration.millis(DateTimeUtils.currentTimeMillis())
-                      .plus(Duration.standardSeconds(60)))
+                  Duration.millis(
+                          DateTimeUtils.currentTimeMillis() / 1000 * 1000) // 
round to seconds
+                      .plus(Duration.standardMinutes(2)))
               .advanceWatermarkToInfinity();
 
       PCollection<Integer> output = pipeline.apply(stream).apply(ParDo.of(fn));
@@ -4193,8 +4194,9 @@ public class ParDoTest implements Serializable {
               .addElements(KV.of("key", "input1"))
               .addElements(KV.of("key", "input2"))
               .advanceProcessingTime(
-                  Duration.millis(DateTimeUtils.currentTimeMillis())
-                      .plus(Duration.standardSeconds(60)))
+                  Duration.millis(
+                          DateTimeUtils.currentTimeMillis() / 1000 * 1000) // 
round to seconds
+                      .plus(Duration.standardMinutes(2)))
               .advanceWatermarkToInfinity();
 
       PCollection<String> output = pipeline.apply(stream).apply(ParDo.of(fn));