Bump beam version dependency

Author: gyfora

docs/content/docs/custom-resource/reference.md

@@ -112,7 +112,7 @@ This serves as a full reference for FlinkDeployment and FlinkSessionJob custom r
 | v1_13 | No longer supported since 1.7 operator release. |
 | v1_14 | No longer supported since 1.7 operator release. |
 | v1_15 | Deprecated since 1.10 operator release. |
-| v1_16 |  |
+| v1_16 | Deprecated since 1.11 operator release. |
 | v1_17 |  |
 | v1_18 |  |
 | v1_19 |  |

examples/flink-beam-example/beam-example.yaml

@@ -22,7 +22,7 @@ metadata:
   name: beam-example
 spec:
   image: flink-beam-example:latest
-  flinkVersion: v1_20
+  flinkVersion: v1_19
   flinkConfiguration:
     taskmanager.numberOfTaskSlots: "1"
   serviceAccount: flink

examples/flink-beam-example/pom.xml

@@ -33,7 +33,7 @@ under the License.
     <!-- Given that this is an example skip maven deployment -->
     <properties>
         <maven.deploy.skip>true</maven.deploy.skip>
-        <beam.version>2.47.0</beam.version>
+        <beam.version>2.62.0</beam.version>
     </properties>
 
     <repositories>
@@ -71,7 +71,7 @@ under the License.
 
         <dependency>
             <groupId>org.apache.beam</groupId>
-            <artifactId>beam-runners-flink-1.16</artifactId>
+            <artifactId>beam-runners-flink-1.19</artifactId>
             <version>${beam.version}</version>
         </dependency>
 

flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersion.java

@@ -32,6 +32,8 @@ public enum FlinkVersion {
     /** Deprecated since 1.10 operator release. */
     @Deprecated
     v1_15(1, 15),
+    /** Deprecated since 1.11 operator release. */
+    @Deprecated
     v1_16(1, 16),
     v1_17(1, 17),
     v1_18(1, 18),
@@ -60,15 +62,6 @@ public boolean isEqualOrNewer(FlinkVersion otherVersion) {
         return false;
     }
 
-    /**
-     * Returns the current version.
-     *
-     * @return The current version.
-     */
-    public static FlinkVersion current() {
-        return values()[values().length - 1];
-    }
-
     public static boolean isSupported(FlinkVersion version) {
         return version != null && version.isEqualOrNewer(FlinkVersion.v1_15);
     }

flink-kubernetes-operator-api/src/test/java/org/apache/flink/kubernetes/operator/api/spec/FlinkVersionTest.java

@@ -33,11 +33,6 @@ void isEqualOrNewer() {
         assertTrue(FlinkVersion.v1_18.isEqualOrNewer(FlinkVersion.v1_17));
     }
 
-    @Test
-    void current() {
-        assertEquals(FlinkVersion.v1_20, FlinkVersion.current());
-    }
-
     @Test
     void isSupported() {
         assertTrue(FlinkVersion.isSupported(FlinkVersion.v1_20));