Hi, Michael Please send email to [email protected] if you want to unsubscribe the mail from [email protected], 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 <[email protected]> 写道： > > unsubscribe > > Best Regards, > > Michael Stollery > > > On Sat, Nov 5, 2022 at 6:17 AM <[email protected]> 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 <[email protected]> >> 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`. >> >> >>
