[dependency] Update flink version and constraint.

Author: wenjin272

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>

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 static boolean supportAsync() {
             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.",

python/flink_agents/plan/actions/utils.py

@@ -29,7 +29,7 @@
 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"),
 ]