You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/09/09 08:21:42 UTC
[flink] branch release-1.11 updated: [FLINK-19094][docs] Revise the
description of watermark strategy in Flink Table document
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 56bce6ef4 [FLINK-19094][docs] Revise the description of watermark strategy in Flink Table document
56bce6ef4 is described below
commit 56bce6ef4aa6fe7119ea5273e1a1fbb1dcde82ef
Author: Leonard Xu <xb...@163.com>
AuthorDate: Wed Sep 9 16:17:51 2020 +0800
[FLINK-19094][docs] Revise the description of watermark strategy in Flink Table document
This closes #13282
---
docs/dev/table/connectors/index.md | 4 ++--
docs/dev/table/connectors/index.zh.md | 4 ++--
docs/dev/table/sql/create.md | 4 ++--
docs/dev/table/sql/create.zh.md | 4 ++--
4 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/docs/dev/table/connectors/index.md b/docs/dev/table/connectors/index.md
index c7fbf6f..f3485a8 100644
--- a/docs/dev/table/connectors/index.md
+++ b/docs/dev/table/connectors/index.md
@@ -228,7 +228,7 @@ The following watermark strategies are supported:
<div data-lang="DDL" markdown="1">
{% highlight sql %}
-- Sets a watermark strategy for strictly ascending rowtime attributes. Emits a watermark of the
--- maximum observed timestamp so far. Rows that have a timestamp smaller to the max timestamp
+-- maximum observed timestamp so far. Rows that have a timestamp bigger to the max timestamp
-- are not late.
CREATE TABLE MyTable (
ts_field TIMESTAMP(3),
@@ -238,7 +238,7 @@ CREATE TABLE MyTable (
)
-- Sets a watermark strategy for ascending rowtime attributes. Emits a watermark of the maximum
--- observed timestamp so far minus 1. Rows that have a timestamp equal to the max timestamp
+-- observed timestamp so far minus 1. Rows that have a timestamp bigger or equal to the max timestamp
-- are not late.
CREATE TABLE MyTable (
ts_field TIMESTAMP(3),
diff --git a/docs/dev/table/connectors/index.zh.md b/docs/dev/table/connectors/index.zh.md
index 6e5ece5..40931c5 100644
--- a/docs/dev/table/connectors/index.zh.md
+++ b/docs/dev/table/connectors/index.zh.md
@@ -228,7 +228,7 @@ The following watermark strategies are supported:
<div data-lang="DDL" markdown="1">
{% highlight sql %}
-- Sets a watermark strategy for strictly ascending rowtime attributes. Emits a watermark of the
--- maximum observed timestamp so far. Rows that have a timestamp smaller to the max timestamp
+-- maximum observed timestamp so far. Rows that have a timestamp bigger to the max timestamp
-- are not late.
CREATE TABLE MyTable (
ts_field TIMESTAMP(3),
@@ -238,7 +238,7 @@ CREATE TABLE MyTable (
)
-- Sets a watermark strategy for ascending rowtime attributes. Emits a watermark of the maximum
--- observed timestamp so far minus 1. Rows that have a timestamp equal to the max timestamp
+-- observed timestamp so far minus 1. Rows that have a timestamp bigger or equal to the max timestamp
-- are not late.
CREATE TABLE MyTable (
ts_field TIMESTAMP(3),
diff --git a/docs/dev/table/sql/create.md b/docs/dev/table/sql/create.md
index 5a449b5..3076d7d 100644
--- a/docs/dev/table/sql/create.md
+++ b/docs/dev/table/sql/create.md
@@ -190,11 +190,11 @@ Flink provides several commonly used watermark strategies.
- Strictly ascending timestamps: `WATERMARK FOR rowtime_column AS rowtime_column`.
- Emits a watermark of the maximum observed timestamp so far. Rows that have a timestamp smaller to the max timestamp are not late.
+ Emits a watermark of the maximum observed timestamp so far. Rows that have a timestamp bigger to the max timestamp are not late.
- Ascending timestamps: `WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL '0.001' SECOND`.
- Emits a watermark of the maximum observed timestamp so far minus 1. Rows that have a timestamp equal and smaller to the max timestamp are not late.
+ Emits a watermark of the maximum observed timestamp so far minus 1. Rows that have a timestamp bigger or equal to the max timestamp are not late.
- Bounded out of orderness timestamps: `WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL 'string' timeUnit`.
diff --git a/docs/dev/table/sql/create.zh.md b/docs/dev/table/sql/create.zh.md
index c0401d9..290cfb7 100644
--- a/docs/dev/table/sql/create.zh.md
+++ b/docs/dev/table/sql/create.zh.md
@@ -190,11 +190,11 @@ Flink 提供了几种常用的 watermark 策略。
- 严格递增时间戳: `WATERMARK FOR rowtime_column AS rowtime_column`。
- 发出到目前为止已观察到的最大时间戳的 watermark ,时间戳小于最大时间戳的行被认为没有迟到。
+ 发出到目前为止已观察到的最大时间戳的 watermark ,时间戳大于最大时间戳的行被认为没有迟到。
- 递增时间戳: `WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL '0.001' SECOND`。
- 发出到目前为止已观察到的最大时间戳减 1 的 watermark ,时间戳等于或小于最大时间戳的行被认为没有迟到。
+ 发出到目前为止已观察到的最大时间戳减 1 的 watermark ,时间戳大于或等于最大时间戳的行被认为没有迟到。
- 有界乱序时间戳: `WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL 'string' timeUnit`。