You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by le...@apache.org on 2022/11/05 13:17:04 UTC
[flink] branch master updated: [hotfix][docs] Set proper watermark and description for event-time temporal table join example
This is an automated email from the ASF dual-hosted git repository.
leonard 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 6a76233bef3 [hotfix][docs] Set proper watermark and description for event-time temporal table join example
6a76233bef3 is described below
commit 6a76233bef3ab2b11952a96013604d8562496353
Author: Jing Ge <ge...@gmail.com>
AuthorDate: Sat Nov 5 14:16:55 2022 +0100
[hotfix][docs] Set proper watermark and description for event-time temporal table join example
---
docs/content.zh/docs/dev/table/sql/queries/joins.md | 8 +++++---
docs/content/docs/dev/table/sql/queries/joins.md | 8 +++++---
2 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/docs/content.zh/docs/dev/table/sql/queries/joins.md b/docs/content.zh/docs/dev/table/sql/queries/joins.md
index 0a5fd96f71c..2ba849153a4 100644
--- a/docs/content.zh/docs/dev/table/sql/queries/joins.md
+++ b/docs/content.zh/docs/dev/table/sql/queries/joins.md
@@ -143,7 +143,7 @@ CREATE TABLE orders (
price DECIMAL(32,2),
currency STRING,
order_time TIMESTAMP(3),
- WATERMARK FOR order_time AS order_time
+ WATERMARK FOR order_time AS order_time - INTERVAL '15' SECOND
) WITH (/* ... */);
-- Define a versioned table of currency rates.
@@ -154,7 +154,7 @@ CREATE TABLE currency_rates (
currency STRING,
conversion_rate DECIMAL(32, 2),
update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp` VIRTUAL,
- WATERMARK FOR update_time AS update_time,
+ WATERMARK FOR update_time AS update_time - INTERVAL '15' SECOND,
PRIMARY KEY(currency) NOT ENFORCED
) WITH (
'connector' = 'kafka',
@@ -179,7 +179,9 @@ o_002 12.51 EUR 1.10 12:06:00
```
-**Note:** The event-time temporal join is triggered by a watermark from the left and right sides; please ensure both sides of the join have set watermark correctly.
+**Note:** The event-time temporal join is triggered by a watermark from the left and right sides.
+The `INTERVAL` time subtraction is used to wait for late events in order to make sure the join will meet the expectation.
+Please ensure both sides of the join have set watermark correctly.
**Note:** The event-time temporal join requires the primary key contained in the equivalence condition of the temporal join condition, e.g., The primary key `currency_rates.currency` of table `currency_rates` to be constrained in the condition `orders.currency = currency_rates.currency`.
diff --git a/docs/content/docs/dev/table/sql/queries/joins.md b/docs/content/docs/dev/table/sql/queries/joins.md
index 4674ffeeb84..97f672ab8ac 100644
--- a/docs/content/docs/dev/table/sql/queries/joins.md
+++ b/docs/content/docs/dev/table/sql/queries/joins.md
@@ -143,7 +143,7 @@ CREATE TABLE orders (
price DECIMAL(32,2),
currency STRING,
order_time TIMESTAMP(3),
- WATERMARK FOR order_time AS order_time
+ WATERMARK FOR order_time AS order_time - INTERVAL '15' SECOND
) WITH (/* ... */);
-- Define a versioned table of currency rates.
@@ -154,7 +154,7 @@ CREATE TABLE currency_rates (
currency STRING,
conversion_rate DECIMAL(32, 2),
update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp` VIRTUAL,
- WATERMARK FOR update_time AS update_time,
+ WATERMARK FOR update_time AS update_time - INTERVAL '15' SECOND,
PRIMARY KEY(currency) NOT ENFORCED
) WITH (
'connector' = 'kafka',
@@ -179,7 +179,9 @@ o_002 12.51 EUR 1.10 12:06:00
```
-**Note:** The event-time temporal join is triggered by a watermark from the left and right sides; please ensure both sides of the join have set watermark correctly.
+**Note:** The event-time temporal join is triggered by a watermark from the left and right sides.
+The `INTERVAL` time subtraction is used to wait for late events in order to make sure the join will meet the expectation.
+Please ensure both sides of the join have set watermark correctly.
**Note:** The event-time temporal join requires the primary key contained in the equivalence condition of the temporal join condition, e.g., The primary key `currency_rates.currency` of table `currency_rates` to be constrained in the condition `orders.currency = currency_rates.currency`.
Re: [flink] branch master updated: [hotfix][docs] Set proper watermark and description for event-time temporal table join example
Posted by Leonard Xu <xb...@gmail.com>.
Hi, Michael
Please send email to commits-unsubscribe@flink.apache.org if you want to unsubscribe the mail from commits@flink.apache.org, you can refer[1] for more details.
Best,
Leonard
[1]https://flink.apache.org/community.html#mailing-lists
> 2022年11月5日 下午10:04，Michael Stollery <mi...@gmail.com> 写道：
>
> unsubscribe
>
> Best Regards,
>
> Michael Stollery
>
>
> On Sat, Nov 5, 2022 at 6:17 AM <le...@apache.org> wrote:
>
>> This is an automated email from the ASF dual-hosted git repository.
>>
>> leonard 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 6a76233bef3 [hotfix][docs] Set proper watermark and description
>> for event-time temporal table join example
>> 6a76233bef3 is described below
>>
>> commit 6a76233bef3ab2b11952a96013604d8562496353
>> Author: Jing Ge <ge...@gmail.com>
>> AuthorDate: Sat Nov 5 14:16:55 2022 +0100
>>
>> [hotfix][docs] Set proper watermark and description for event-time
>> temporal table join example
>> ---
>> docs/content.zh/docs/dev/table/sql/queries/joins.md | 8 +++++---
>> docs/content/docs/dev/table/sql/queries/joins.md | 8 +++++---
>> 2 files changed, 10 insertions(+), 6 deletions(-)
>>
>> diff --git a/docs/content.zh/docs/dev/table/sql/queries/joins.md
>> b/docs/content.zh/docs/dev/table/sql/queries/joins.md
>> index 0a5fd96f71c..2ba849153a4 100644
>> --- a/docs/content.zh/docs/dev/table/sql/queries/joins.md
>> +++ b/docs/content.zh/docs/dev/table/sql/queries/joins.md
>> @@ -143,7 +143,7 @@ CREATE TABLE orders (
>> price DECIMAL(32,2),
>> currency STRING,
>> order_time TIMESTAMP(3),
>> - WATERMARK FOR order_time AS order_time
>> + WATERMARK FOR order_time AS order_time - INTERVAL '15' SECOND
>> ) WITH (/* ... */);
>>
>> -- Define a versioned table of currency rates.
>> @@ -154,7 +154,7 @@ CREATE TABLE currency_rates (
>> currency STRING,
>> conversion_rate DECIMAL(32, 2),
>> update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp`
>> VIRTUAL,
>> - WATERMARK FOR update_time AS update_time,
>> + WATERMARK FOR update_time AS update_time - INTERVAL '15' SECOND,
>> PRIMARY KEY(currency) NOT ENFORCED
>> ) WITH (
>> 'connector' = 'kafka',
>> @@ -179,7 +179,9 @@ o_002 12.51 EUR 1.10 12:06:00
>>
>> ```
>>
>> -**Note:** The event-time temporal join is triggered by a watermark from
>> the left and right sides; please ensure both sides of the join have set
>> watermark correctly.
>> +**Note:** The event-time temporal join is triggered by a watermark from
>> the left and right sides.
>> +The `INTERVAL` time subtraction is used to wait for late events in order
>> to make sure the join will meet the expectation.
>> +Please ensure both sides of the join have set watermark correctly.
>>
>> **Note:** The event-time temporal join requires the primary key contained
>> in the equivalence condition of the temporal join condition, e.g., The
>> primary key `currency_rates.currency` of table `currency_rates` to be
>> constrained in the condition `orders.currency = currency_rates.currency`.
>>
>> diff --git a/docs/content/docs/dev/table/sql/queries/joins.md
>> b/docs/content/docs/dev/table/sql/queries/joins.md
>> index 4674ffeeb84..97f672ab8ac 100644
>> --- a/docs/content/docs/dev/table/sql/queries/joins.md
>> +++ b/docs/content/docs/dev/table/sql/queries/joins.md
>> @@ -143,7 +143,7 @@ CREATE TABLE orders (
>> price DECIMAL(32,2),
>> currency STRING,
>> order_time TIMESTAMP(3),
>> - WATERMARK FOR order_time AS order_time
>> + WATERMARK FOR order_time AS order_time - INTERVAL '15' SECOND
>> ) WITH (/* ... */);
>>
>> -- Define a versioned table of currency rates.
>> @@ -154,7 +154,7 @@ CREATE TABLE currency_rates (
>> currency STRING,
>> conversion_rate DECIMAL(32, 2),
>> update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp`
>> VIRTUAL,
>> - WATERMARK FOR update_time AS update_time,
>> + WATERMARK FOR update_time AS update_time - INTERVAL '15' SECOND,
>> PRIMARY KEY(currency) NOT ENFORCED
>> ) WITH (
>> 'connector' = 'kafka',
>> @@ -179,7 +179,9 @@ o_002 12.51 EUR 1.10 12:06:00
>>
>> ```
>>
>> -**Note:** The event-time temporal join is triggered by a watermark from
>> the left and right sides; please ensure both sides of the join have set
>> watermark correctly.
>> +**Note:** The event-time temporal join is triggered by a watermark from
>> the left and right sides.
>> +The `INTERVAL` time subtraction is used to wait for late events in order
>> to make sure the join will meet the expectation.
>> +Please ensure both sides of the join have set watermark correctly.
>>
>> **Note:** The event-time temporal join requires the primary key contained
>> in the equivalence condition of the temporal join condition, e.g., The
>> primary key `currency_rates.currency` of table `currency_rates` to be
>> constrained in the condition `orders.currency = currency_rates.currency`.
>>
>>
>>
Re: [flink] branch master updated: [hotfix][docs] Set proper watermark and description for event-time temporal table join example
Posted by Michael Stollery <mi...@gmail.com>.
unsubscribe
Best Regards,
Michael Stollery
On Sat, Nov 5, 2022 at 6:17 AM <le...@apache.org> wrote:
> This is an automated email from the ASF dual-hosted git repository.
>
> leonard 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 6a76233bef3 [hotfix][docs] Set proper watermark and description
> for event-time temporal table join example
> 6a76233bef3 is described below
>
> commit 6a76233bef3ab2b11952a96013604d8562496353
> Author: Jing Ge <ge...@gmail.com>
> AuthorDate: Sat Nov 5 14:16:55 2022 +0100
>
> [hotfix][docs] Set proper watermark and description for event-time
> temporal table join example
> ---
> docs/content.zh/docs/dev/table/sql/queries/joins.md | 8 +++++---
> docs/content/docs/dev/table/sql/queries/joins.md | 8 +++++---
> 2 files changed, 10 insertions(+), 6 deletions(-)
>
> diff --git a/docs/content.zh/docs/dev/table/sql/queries/joins.md
> b/docs/content.zh/docs/dev/table/sql/queries/joins.md
> index 0a5fd96f71c..2ba849153a4 100644
> --- a/docs/content.zh/docs/dev/table/sql/queries/joins.md
> +++ b/docs/content.zh/docs/dev/table/sql/queries/joins.md
> @@ -143,7 +143,7 @@ CREATE TABLE orders (
> price DECIMAL(32,2),
> currency STRING,
> order_time TIMESTAMP(3),
> - WATERMARK FOR order_time AS order_time
> + WATERMARK FOR order_time AS order_time - INTERVAL '15' SECOND
> ) WITH (/* ... */);
>
> -- Define a versioned table of currency rates.
> @@ -154,7 +154,7 @@ CREATE TABLE currency_rates (
> currency STRING,
> conversion_rate DECIMAL(32, 2),
> update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp`
> VIRTUAL,
> - WATERMARK FOR update_time AS update_time,
> + WATERMARK FOR update_time AS update_time - INTERVAL '15' SECOND,
> PRIMARY KEY(currency) NOT ENFORCED
> ) WITH (
> 'connector' = 'kafka',
> @@ -179,7 +179,9 @@ o_002 12.51 EUR 1.10 12:06:00
>
> ```
>
> -**Note:** The event-time temporal join is triggered by a watermark from
> the left and right sides; please ensure both sides of the join have set
> watermark correctly.
> +**Note:** The event-time temporal join is triggered by a watermark from
> the left and right sides.
> +The `INTERVAL` time subtraction is used to wait for late events in order
> to make sure the join will meet the expectation.
> +Please ensure both sides of the join have set watermark correctly.
>
> **Note:** The event-time temporal join requires the primary key contained
> in the equivalence condition of the temporal join condition, e.g., The
> primary key `currency_rates.currency` of table `currency_rates` to be
> constrained in the condition `orders.currency = currency_rates.currency`.
>
> diff --git a/docs/content/docs/dev/table/sql/queries/joins.md
> b/docs/content/docs/dev/table/sql/queries/joins.md
> index 4674ffeeb84..97f672ab8ac 100644
> --- a/docs/content/docs/dev/table/sql/queries/joins.md
> +++ b/docs/content/docs/dev/table/sql/queries/joins.md
> @@ -143,7 +143,7 @@ CREATE TABLE orders (
> price DECIMAL(32,2),
> currency STRING,
> order_time TIMESTAMP(3),
> - WATERMARK FOR order_time AS order_time
> + WATERMARK FOR order_time AS order_time - INTERVAL '15' SECOND
> ) WITH (/* ... */);
>
> -- Define a versioned table of currency rates.
> @@ -154,7 +154,7 @@ CREATE TABLE currency_rates (
> currency STRING,
> conversion_rate DECIMAL(32, 2),
> update_time TIMESTAMP(3) METADATA FROM `values.source.timestamp`
> VIRTUAL,
> - WATERMARK FOR update_time AS update_time,
> + WATERMARK FOR update_time AS update_time - INTERVAL '15' SECOND,
> PRIMARY KEY(currency) NOT ENFORCED
> ) WITH (
> 'connector' = 'kafka',
> @@ -179,7 +179,9 @@ o_002 12.51 EUR 1.10 12:06:00
>
> ```
>
> -**Note:** The event-time temporal join is triggered by a watermark from
> the left and right sides; please ensure both sides of the join have set
> watermark correctly.
> +**Note:** The event-time temporal join is triggered by a watermark from
> the left and right sides.
> +The `INTERVAL` time subtraction is used to wait for late events in order
> to make sure the join will meet the expectation.
> +Please ensure both sides of the join have set watermark correctly.
>
> **Note:** The event-time temporal join requires the primary key contained
> in the equivalence condition of the temporal join condition, e.g., The
> primary key `currency_rates.currency` of table `currency_rates` to be
> constrained in the condition `orders.currency = currency_rates.currency`.
>
>
>