(flink-connector-kafka) branch main updated: [hotfix] Fix Python CI

[ma...@apache.org]

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 <29...@users.noreply.github.com>
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 = \