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`。