This is an automated email from the ASF dual-hosted git repository.
jark 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 1fc26192cf7 [hotfix][doc] fix the mismatch result in Window Join
example (#19665)
1fc26192cf7 is described below
commit 1fc26192cf794961af4f6933c155daf86eb8a0fe
Author: TennyZhuang <[email protected]>
AuthorDate: Sun May 8 20:45:01 2022 +0800
[hotfix][doc] fix the mismatch result in Window Join example (#19665)
Signed-off-by: TennyZhuang <[email protected]>
---
docs/content.zh/docs/dev/table/sql/queries/window-join.md | 4 +++-
docs/content/docs/dev/table/sql/queries/window-join.md | 4 +++-
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/dev/table/sql/queries/window-join.md
b/docs/content.zh/docs/dev/table/sql/queries/window-join.md
index dbbb3dc17b8..6421ee3ffdd 100644
--- a/docs/content.zh/docs/dev/table/sql/queries/window-join.md
+++ b/docs/content.zh/docs/dev/table/sql/queries/window-join.md
@@ -86,7 +86,9 @@ Flink SQL> SELECT * FROM RightTable;
| 2020-04-15 12:05 | 4 | R4 |
+------------------+-----+----+
-Flink SQL> SELECT L.num as L_Num, L.id as L_Id, R.num as R_Num, R.id as R_Id,
L.window_start, L.window_end
+Flink SQL> SELECT L.num as L_Num, L.id as L_Id, R.num as R_Num, R.id as R_Id,
+ COALESCE(L.window_start, R.window_start) as window_start,
+ COALESCE(L.window_end, R.window_end) as window_end
FROM (
SELECT * FROM TABLE(TUMBLE(TABLE LeftTable,
DESCRIPTOR(row_time), INTERVAL '5' MINUTES))
) L
diff --git a/docs/content/docs/dev/table/sql/queries/window-join.md
b/docs/content/docs/dev/table/sql/queries/window-join.md
index 81af1ed886e..d0c8d635689 100644
--- a/docs/content/docs/dev/table/sql/queries/window-join.md
+++ b/docs/content/docs/dev/table/sql/queries/window-join.md
@@ -86,7 +86,9 @@ Flink SQL> SELECT * FROM RightTable;
| 2020-04-15 12:05 | 4 | R4 |
+------------------+-----+----+
-Flink SQL> SELECT L.num as L_Num, L.id as L_Id, R.num as R_Num, R.id as R_Id,
L.window_start, L.window_end
+Flink SQL> SELECT L.num as L_Num, L.id as L_Id, R.num as R_Num, R.id as R_Id,
+ COALESCE(L.window_start, R.window_start) as window_start,
+ COALESCE(L.window_end, R.window_end) as window_end
FROM (
SELECT * FROM TABLE(TUMBLE(TABLE LeftTable,
DESCRIPTOR(row_time), INTERVAL '5' MINUTES))
) L
