This is an automated email from the ASF dual-hosted git repository.
MartijnVisser 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 9e663f3e3ad [hotfix][docs] Fix broken link in PyFlink documentation
9e663f3e3ad is described below
commit 9e663f3e3adeddb476d43d430e2b3969259c3395
Author: Zihao Chen <[email protected]>
AuthorDate: Mon Jun 29 16:45:53 2026 +0800
[hotfix][docs] Fix broken link in PyFlink documentation
---
flink-python/README.md | 6 +++---
flink-python/docs/user_guide/table_api_tutorial.rst | 2 +-
.../pyflink/examples/table/mixing_use_of_datastream_and_table.py | 2 +-
flink-python/pyflink/examples/table/multi_sink.py | 2 +-
flink-python/pyflink/examples/table/pandas/pandas_udaf.py | 2 +-
flink-python/pyflink/examples/table/process_json_data.py | 2 +-
flink-python/pyflink/examples/table/process_json_data_with_udf.py | 2 +-
flink-python/pyflink/examples/table/streaming_word_count.py | 2 +-
flink-python/pyflink/examples/table/windowing/over_window.py | 2 +-
flink-python/pyflink/examples/table/windowing/session_window.py | 2 +-
flink-python/pyflink/examples/table/windowing/sliding_window.py | 2 +-
flink-python/pyflink/examples/table/windowing/tumble_window.py | 2 +-
flink-python/pyflink/examples/table/word_count.py | 2 +-
13 files changed, 15 insertions(+), 15 deletions(-)
diff --git a/flink-python/README.md b/flink-python/README.md
index 32f5a95ce59..f30b5c059d1 100644
--- a/flink-python/README.md
+++ b/flink-python/README.md
@@ -14,13 +14,13 @@ Depending on the level of abstraction you need, there are
two different APIs tha
The PyFlink Table API allows you to write powerful relational queries in a way
that is similar to
using SQL or working with tabular data in Python. You can find more
information about it via the tutorial
-[https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/table_api_tutorial/](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/table_api_tutorial/)
+[https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/table_api_tutorial.html](https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/table_api_tutorial.html)
The PyFlink DataStream API gives you lower-level control over the core
building blocks of Flink,
state and time, to build more complex stream processing use cases.
-Tutorial can be found at
[https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/datastream_tutorial/](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/datastream_tutorial/)
+Tutorial can be found at
[https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/datastream_tutorial.html](https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/datastream_tutorial.html)
-You can find more information via the documentation at
[https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/overview/](https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/overview/)
+You can find more information via the documentation at
[https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/overview.html](https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/overview.html)
The auto-generated Python docs can be found at
[https://nightlies.apache.org/flink/flink-docs-stable/api/python/](https://nightlies.apache.org/flink/flink-docs-stable/api/python/)
diff --git a/flink-python/docs/user_guide/table_api_tutorial.rst
b/flink-python/docs/user_guide/table_api_tutorial.rst
index 4041b3a6449..6bd2c01c00c 100644
--- a/flink-python/docs/user_guide/table_api_tutorial.rst
+++ b/flink-python/docs/user_guide/table_api_tutorial.rst
@@ -281,7 +281,7 @@ The complete code so far:
.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git
a/flink-python/pyflink/examples/table/mixing_use_of_datastream_and_table.py
b/flink-python/pyflink/examples/table/mixing_use_of_datastream_and_table.py
index 3dc9b7d82dd..49450aa1c5c 100644
--- a/flink-python/pyflink/examples/table/mixing_use_of_datastream_and_table.py
+++ b/flink-python/pyflink/examples/table/mixing_use_of_datastream_and_table.py
@@ -71,7 +71,7 @@ def mixing_use_of_datastream_and_table():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/multi_sink.py
b/flink-python/pyflink/examples/table/multi_sink.py
index 966cb5fe70f..403a9b9e0fe 100644
--- a/flink-python/pyflink/examples/table/multi_sink.py
+++ b/flink-python/pyflink/examples/table/multi_sink.py
@@ -64,7 +64,7 @@ def multi_sink():
# execute the statement set
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
statement_set.execute().wait()
diff --git a/flink-python/pyflink/examples/table/pandas/pandas_udaf.py
b/flink-python/pyflink/examples/table/pandas/pandas_udaf.py
index 72febe590e7..f444614f3fe 100644
--- a/flink-python/pyflink/examples/table/pandas/pandas_udaf.py
+++ b/flink-python/pyflink/examples/table/pandas/pandas_udaf.py
@@ -82,7 +82,7 @@ def pandas_udaf():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/process_json_data.py
b/flink-python/pyflink/examples/table/process_json_data.py
index b410d11c58e..a0acf774c32 100644
--- a/flink-python/pyflink/examples/table/process_json_data.py
+++ b/flink-python/pyflink/examples/table/process_json_data.py
@@ -52,7 +52,7 @@ def process_json_data():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/process_json_data_with_udf.py
b/flink-python/pyflink/examples/table/process_json_data_with_udf.py
index 934e73a68d8..da7d74728d6 100644
--- a/flink-python/pyflink/examples/table/process_json_data_with_udf.py
+++ b/flink-python/pyflink/examples/table/process_json_data_with_udf.py
@@ -61,7 +61,7 @@ def process_json_data_with_udf():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/streaming_word_count.py
b/flink-python/pyflink/examples/table/streaming_word_count.py
index eb36c7a25db..e6034cfafc8 100644
--- a/flink-python/pyflink/examples/table/streaming_word_count.py
+++ b/flink-python/pyflink/examples/table/streaming_word_count.py
@@ -84,7 +84,7 @@ def streaming_word_count(output_path):
.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/windowing/over_window.py
b/flink-python/pyflink/examples/table/windowing/over_window.py
index d958e75ddc1..19f91266390 100644
--- a/flink-python/pyflink/examples/table/windowing/over_window.py
+++ b/flink-python/pyflink/examples/table/windowing/over_window.py
@@ -79,7 +79,7 @@ def tumble_window_demo():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/windowing/session_window.py
b/flink-python/pyflink/examples/table/windowing/session_window.py
index e7506b0f8b3..bb8b508bae1 100644
--- a/flink-python/pyflink/examples/table/windowing/session_window.py
+++ b/flink-python/pyflink/examples/table/windowing/session_window.py
@@ -75,7 +75,7 @@ def session_window_demo():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/windowing/sliding_window.py
b/flink-python/pyflink/examples/table/windowing/sliding_window.py
index 10ba068b1a5..b91071e750b 100644
--- a/flink-python/pyflink/examples/table/windowing/sliding_window.py
+++ b/flink-python/pyflink/examples/table/windowing/sliding_window.py
@@ -77,7 +77,7 @@ def sliding_window_demo():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/windowing/tumble_window.py
b/flink-python/pyflink/examples/table/windowing/tumble_window.py
index ff5bb99516e..9f04673b84d 100644
--- a/flink-python/pyflink/examples/table/windowing/tumble_window.py
+++ b/flink-python/pyflink/examples/table/windowing/tumble_window.py
@@ -77,7 +77,7 @@ def tumble_window_demo():
table.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
diff --git a/flink-python/pyflink/examples/table/word_count.py
b/flink-python/pyflink/examples/table/word_count.py
index a0283048925..b84ac645444 100644
--- a/flink-python/pyflink/examples/table/word_count.py
+++ b/flink-python/pyflink/examples/table/word_count.py
@@ -121,7 +121,7 @@ def word_count(input_path, output_path):
.execute_insert('sink') \
.wait()
# remove .wait if submitting to a remote cluster, refer to
- #
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/python/faq/#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
+ #
https://nightlies.apache.org/flink/flink-docs-stable/api/python/user_guide/faq.html#wait-for-jobs-to-finish-when-executing-jobs-in-mini-cluster
# for more details
