This is an automated email from the ASF dual-hosted git repository. wenjin272 pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-agents.git
commit cfb712701ccfe51c384e835f1dae37e8f7f67739 Author: WenjinXie <[email protected]> AuthorDate: Sat May 16 18:36:08 2026 +0800 [dependency] Update flink version and constraint. --- dist/pom.xml | 8 ++++---- .../src/main/java/org/apache/flink/agents/plan/actions/Utils.java | 6 +++--- python/flink_agents/plan/actions/utils.py | 2 +- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/dist/pom.xml b/dist/pom.xml index f7e064f6..40fcc7b1 100644 --- a/dist/pom.xml +++ b/dist/pom.xml @@ -30,10 +30,10 @@ under the License. <packaging>pom</packaging> <properties> - <flink.1.20.version>1.20.3</flink.1.20.version> - <flink.2.0.version>2.0.1</flink.2.0.version> - <flink.2.1.version>2.1.1</flink.2.1.version> - <flink.2.2.version>2.2.0</flink.2.2.version> + <flink.1.20.version>1.20.4</flink.1.20.version> + <flink.2.0.version>2.0.2</flink.2.0.version> + <flink.2.1.version>2.1.2</flink.2.1.version> + <flink.2.2.version>2.2.1</flink.2.2.version> </properties> <modules> diff --git a/plan/src/main/java/org/apache/flink/agents/plan/actions/Utils.java b/plan/src/main/java/org/apache/flink/agents/plan/actions/Utils.java index 87c63d69..47f60fb2 100644 --- a/plan/src/main/java/org/apache/flink/agents/plan/actions/Utils.java +++ b/plan/src/main/java/org/apache/flink/agents/plan/actions/Utils.java @@ -30,7 +30,7 @@ public final class Utils { private static final Logger LOG = LoggerFactory.getLogger(Utils.class); private static final String DEFAULT_VALUE = "<unknown>"; public static final List<String> requiredVersions = - List.of("1.20.4", "2.0.1", "2.1.1", "2.2.0"); + List.of("1.20.4", "2.0.1", "2.1.2", "2.2.0"); static final Versions INSTANCE = new Versions(); @@ -57,9 +57,9 @@ public final class Utils { int minor = Integer.parseInt(st.nextToken()); int micro = Integer.parseInt(st.nextToken()); - if ((major == 1 && (minor < 20 || (minor == 20 && micro <= 3))) + if ((major == 1 && (minor < 20 || (minor == 20 && micro <= 4))) || (major == 2 && minor == 0 && micro <= 1) - || (major == 2 && minor == 1 && micro <= 1) + || (major == 2 && minor == 1 && micro <= 2) || (major == 2 && minor == 2 && micro <= 0)) { LOG.debug( "Flink {} doesn't support async execution for java resource, will fallback to sync execution.", diff --git a/python/flink_agents/plan/actions/utils.py b/python/flink_agents/plan/actions/utils.py index 30f24a03..5f1bbb2b 100644 --- a/python/flink_agents/plan/actions/utils.py +++ b/python/flink_agents/plan/actions/utils.py @@ -29,7 +29,7 @@ from packaging import version as pkg_version UNSUPPORTED_RANGES: List[Tuple[str, str]] = [ ("1.0.0", "1.20.4"), ("2.0.0", "2.0.1"), - ("2.1.0", "2.1.1"), + ("2.1.0", "2.1.2"), ("2.2.0", "2.2.0"), ]
