Changes watermark advance from 1001 to 1000 since Dataflow TestStream…

… only advances watermark at 1s resolution.
mransley · Jan 15, 2020 · 17398f7 · 17398f7
1 parent 2021531
commit 17398f7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/testing/TestStreamTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/testing/TestStreamTest.java
@@ -191,7 +191,7 @@ public void testDiscardingMode() {
  TimestampedValue.of("firstPane", new Instant(100)),
  TimestampedValue.of("alsoFirstPane", new Instant(200)))
  .addElements(TimestampedValue.of("onTimePane", new Instant(500)))
- .advanceWatermarkTo(new Instant(1001L))
+ .advanceWatermarkTo(new Instant(1000L))
  .addElements(
  TimestampedValue.of("finalLatePane", new Instant(750)),
  TimestampedValue.of("alsoFinalLatePane", new Instant(250)))