This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.1 by this push:
new ca506130a3a [FLINK-38094][python] Introduce pyflink.__version__
ca506130a3a is described below
commit ca506130a3a9b9624f2776112a99c5df5f4ddb0a
Author: Yun Tang <myas...@live.com>
AuthorDate: Sun Jul 13 22:01:46 2025 +0800
[FLINK-38094][python] Introduce pyflink.__version__
This closes #26793.
---
flink-python/pyflink/__init__.py | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/flink-python/pyflink/__init__.py b/flink-python/pyflink/__init__.py
index 4d1bdbdcb62..e9819738a00 100644
--- a/flink-python/pyflink/__init__.py
+++ b/flink-python/pyflink/__init__.py
@@ -25,6 +25,8 @@ if sys.version_info < (3, 6):
'Python versions prior to 3.6 are not supported for PyFlink [' +
str(sys.version_info) + '].')
+from pyflink.version import __version__
+
def keyword(func):
"""
@@ -50,3 +52,7 @@ def add_version_doc(f, version):
indents = indent_p.findall(original_doc)
indent = ' ' * (min(len(indent) for indent in indents) if indents else 0)
f.__doc__ = original_doc.rstrip() + "\n\n%s.. versionadded:: %s" %
(indent, version)
+
+__all__ = [
+ "__version__",
+]
