This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new d10088b3 [hotfix] Fix Python CI
d10088b3 is described below
commit d10088b3f6b4b4f9b3b5a05649fe1a8f53e41589
Author: Martijn Visser <[email protected]>
AuthorDate: Wed Nov 19 10:41:47 2025 +0100
[hotfix] Fix Python CI
---
flink-python/setup.py | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
diff --git a/flink-python/setup.py b/flink-python/setup.py
index 76cecf45..937b659b 100644
--- a/flink-python/setup.py
+++ b/flink-python/setup.py
@@ -81,7 +81,17 @@ def prepare_pyflink_dir():
connector_version = pom_root.findall(
"./{http://maven.apache.org/POM/4.0.0}version";)[0].text.replace("-SNAPSHOT",
".dev0")
- flink_dependency = "apache-flink>=" + flink_version
+ # Pin to the minor version (e.g., >=1.19.1,<1.20.0) to allow patch updates
+ # but prevent major/minor version upgrades
+ version_parts = flink_version.split('.')
+ if len(version_parts) >= 2:
+ next_minor = str(int(version_parts[1]) + 1)
+ next_version = version_parts[0] + '.' + next_minor + '.0'
+ flink_dependency = "apache-flink>=" + flink_version + ",<" +
next_version
+ else:
+ # Fallback to exact match if version format is unexpected
+ print("Falling back to exact match for unexpected version format: " +
flink_version)
+ flink_dependency = "apache-flink==" + flink_version
os.makedirs(LIB_PATH)
connector_jar = \
