unsubscribe Best Regards,
Michael Stollery On Sat, Nov 5, 2022 at 6:17 AM <leon...@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 <gej...@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`. > > >
