This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new 7b8621f [hotfix][python][docs] Correct the docs of interval join
7b8621f is described below
commit 7b8621fe37a3feb220d3f8e8f91defdebe7a2d36
Author: Dian Fu <[email protected]>
AuthorDate: Mon Jul 19 10:56:33 2021 +0800
[hotfix][python][docs] Correct the docs of interval join
---
docs/content.zh/docs/dev/table/tableApi.md | 2 +-
docs/content/docs/dev/table/tableApi.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content.zh/docs/dev/table/tableApi.md
b/docs/content.zh/docs/dev/table/tableApi.md
index 76cd568..1aee614 100644
--- a/docs/content.zh/docs/dev/table/tableApi.md
+++ b/docs/content.zh/docs/dev/table/tableApi.md
@@ -1007,7 +1007,7 @@ from pyflink.table.expressions import col
left = t_env.from_path("Source1").select(col('a'), col('b'), col('c'),
col('rowtime1'))
right = t_env.from_path("Source2").select(col('d'), col('e'), col('f'),
col('rowtime2'))
-joined_table = left.join(right).where(left.a == right.d & left.rowtime1 >=
right.rowtime2 - lit(1).second & left.rowtime1 <= right.rowtime2 +
lit(2).seconds)
+joined_table = left.join(right).where((left.a == right.d) & (left.rowtime1 >=
right.rowtime2 - lit(1).second) & (left.rowtime1 <= right.rowtime2 +
lit(2).seconds))
result = joined_table.select(joined_table.a, joined_table.b, joined_table.e,
joined_table.rowtime1)
```
{{< /tab >}}
diff --git a/docs/content/docs/dev/table/tableApi.md
b/docs/content/docs/dev/table/tableApi.md
index 9a7beec..c3c689d 100644
--- a/docs/content/docs/dev/table/tableApi.md
+++ b/docs/content/docs/dev/table/tableApi.md
@@ -1007,7 +1007,7 @@ from pyflink.table.expressions import col
left = t_env.from_path("Source1").select(col('a'), col('b'), col('c'),
col('rowtime1'))
right = t_env.from_path("Source2").select(col('d'), col('e'), col('f'),
col('rowtime2'))
-joined_table = left.join(right).where(left.a == right.d & left.rowtime1 >=
right.rowtime2 - lit(1).second & left.rowtime1 <= right.rowtime2 +
lit(2).seconds)
+joined_table = left.join(right).where((left.a == right.d) & (left.rowtime1 >=
right.rowtime2 - lit(1).second) & (left.rowtime1 <= right.rowtime2 +
lit(2).seconds))
result = joined_table.select(joined_table.a, joined_table.b, joined_table.e,
joined_table.rowtime1)
```
{{< /tab >}}
