You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2022/01/03 14:56:29 UTC
[flink] branch master updated: [hotfix][docs] Remove duplicate dot in generating_watermarks.md
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 6681a47 [hotfix][docs] Remove duplicate dot in generating_watermarks.md
6681a47 is described below
commit 6681a47fc5b841e90e6d68680ea4491fa6137c5a
Author: wangzhuo <wz...@sina.com>
AuthorDate: Thu Dec 23 11:47:14 2021 +0800
[hotfix][docs] Remove duplicate dot in generating_watermarks.md
---
docs/content.zh/docs/dev/datastream/event-time/generating_watermarks.md | 2 +-
docs/content/docs/dev/datastream/event-time/generating_watermarks.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/dev/datastream/event-time/generating_watermarks.md b/docs/content.zh/docs/dev/datastream/event-time/generating_watermarks.md
index 1f8d099..bed1bc5 100644
--- a/docs/content.zh/docs/dev/datastream/event-time/generating_watermarks.md
+++ b/docs/content.zh/docs/dev/datastream/event-time/generating_watermarks.md
@@ -366,7 +366,7 @@ class PunctuatedAssigner extends AssignerWithPunctuatedWatermarks[MyEvent] {
```java
FlinkKafkaConsumer<MyType> kafkaSource = new FlinkKafkaConsumer<>("myTopic", schema, props);
kafkaSource.assignTimestampsAndWatermarks(
- WatermarkStrategy.
+ WatermarkStrategy
.forBoundedOutOfOrderness(Duration.ofSeconds(20)));
DataStream<MyType> stream = env.addSource(kafkaSource);
diff --git a/docs/content/docs/dev/datastream/event-time/generating_watermarks.md b/docs/content/docs/dev/datastream/event-time/generating_watermarks.md
index aa95ed9..9d1bb83 100644
--- a/docs/content/docs/dev/datastream/event-time/generating_watermarks.md
+++ b/docs/content/docs/dev/datastream/event-time/generating_watermarks.md
@@ -439,7 +439,7 @@ case.
```java
FlinkKafkaConsumer<MyType> kafkaSource = new FlinkKafkaConsumer<>("myTopic", schema, props);
kafkaSource.assignTimestampsAndWatermarks(
- WatermarkStrategy.
+ WatermarkStrategy
.forBoundedOutOfOrderness(Duration.ofSeconds(20)));
DataStream<MyType> stream = env.addSource(kafkaSource);