This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch v3.3 in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
commit 9f631be2c0d2b01746df4df94e47a07dde169f2c Author: Martijn Visser <[email protected]> AuthorDate: Tue Nov 18 18:57:07 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 8e788d4e..98dd13e3 100644 --- a/flink-python/setup.py +++ b/flink-python/setup.py @@ -81,7 +81,16 @@ 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 + flink_dependency = "apache-flink==" + flink_version os.makedirs(LIB_PATH) connector_jar = \ @@ -133,6 +142,7 @@ if in_flink_source: # Runs the python setup setup( + py_modules=[], name=PACKAGE_NAME, version=connector_version, include_package_data=True,
