From 6adf544fc81e07fdbd2a08b2c7dc4d14db9c6257 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Goulven=20LE=20D=C3=9B?= Date: Fri, 8 Aug 2025 17:00:50 +0200 Subject: [PATCH 1/2] docs: fix python docstring --- flink-python/pyflink/common/watermark_strategy.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-python/pyflink/common/watermark_strategy.py b/flink-python/pyflink/common/watermark_strategy.py index 532e962b06a2f..e305d5a441199 100644 --- a/flink-python/pyflink/common/watermark_strategy.py +++ b/flink-python/pyflink/common/watermark_strategy.py @@ -128,8 +128,8 @@ def for_bounded_out_of_orderness(max_out_of_orderness: Duration) -> 'WatermarkSt """ Creates a watermark strategy for situations where records are out of order, but you can place an upper bound on how far the events are out of order. An out-of-order bound B means - that once the an event with timestamp T was encountered, no events older than (T - B) will - follow any more. + that once an event with timestamp T was encountered, no events older than (T - B) will + follow anymore. """ JWaterMarkStrategy = get_gateway().jvm \ .org.apache.flink.api.common.eventtime.WatermarkStrategy From ba921f84eda444224220713746ad0a66f4edf161 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Goulven=20LE=20D=C3=9B?= Date: Fri, 8 Aug 2025 17:00:59 +0200 Subject: [PATCH 2/2] docs: fix javadoc --- .../apache/flink/api/common/eventtime/WatermarkStrategy.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java index 388ef68c7fd51..6caa2bbee8271 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java @@ -223,8 +223,8 @@ static WatermarkStrategy forMonotonousTimestamps() { /** * Creates a watermark strategy for situations where records are out of order, but you can place * an upper bound on how far the events are out of order. An out-of-order bound B means that - * once the an event with timestamp T was encountered, no events older than {@code T - B} will - * follow any more. + * once an event with timestamp T was encountered, no events older than {@code T - B} will + * follow anymore. * *

The watermarks are generated periodically. The delay introduced by this watermark strategy * is the periodic interval length, plus the out of orderness bound.