[FLINK-35649] Bump Flink version to 1.19.1 in k8s-operator

Author: ferenc-csaky

.github/workflows/ci.yml

@@ -47,13 +47,8 @@ jobs:
             ${{ runner.os }}-maven-
       - name: Build with Maven
         run: |
-          set -o pipefail; mvn -B clean install javadoc:javadoc -Pgenerate-docs | tee ./mvn.log; set +o pipefail
-          if [[ $(cat ./mvn.log | grep -E -v '(flink-runtime-.*.jar, flink-kubernetes-operator-.*.jar)|(flink-kubernetes-operator-.*.jar, flink-runtime-.*.jar) define 3 overlapping classes' | grep -E -v '(flink-runtime-.*.jar, flink-autoscaler-.*.jar)|(flink-autoscaler-.*.jar, flink-runtime-.*.jar) define 1|2 overlapping classes' | grep -c "overlapping classes" -) -gt 0 ]];then
-            echo "Found overlapping classes: "
-            cat ./mvn.log | grep "overlapping classes"
-            exit 1
-          fi
-          if [[ $(git diff HEAD | wc -l) -gt 0 ]];then
+          mvn -B clean install javadoc:javadoc -Pgenerate-docs
+          if [[ $(git diff HEAD | wc -l) -gt 0 ]]; then
             echo "Please generate the java doc via 'mvn clean install -DskipTests -Pgenerate-docs' again"
             exit 1
           fi

flink-autoscaler-plugin-jdbc/pom.xml

@@ -104,6 +104,12 @@ under the License.
             </exclusions>
         </dependency>
 
+        <dependency>
+            <groupId>commons-codec</groupId>
+            <artifactId>commons-codec</artifactId>
+            <version>1.17.0</version>
+        </dependency>
+
         <!-- Derby tests -->
         <dependency>
             <groupId>org.apache.derby</groupId>

flink-autoscaler/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java

@@ -45,7 +45,7 @@
 import java.util.Map;
 import java.util.Objects;
 
-/** Copied from Flink. Should be removed once the client dependency is upgraded to 1.18. */
+/** Copied from Flink. Should be removed once the client dependency is upgraded to 1.20. */
 /** The difference compared to 1.18 is that slot sharing group is optional here. */
 public class JobDetailsInfo implements ResponseBody {
 

flink-kubernetes-operator/pom.xml

@@ -251,6 +251,12 @@ under the License.
                                         <exclude>META-INF/**/module-info.class</exclude>
                                     </excludes>
                                 </filter>
+                                <filter>
+                                    <artifact>org.apache.flink:flink-kubernetes</artifact>
+                                    <excludes>
+                                        <exclude>META-INF/versions/**/com/fasterxml/jackson/core/io/doubleparser/**</exclude>
+                                    </excludes>
+                                </filter>
                             </filters>
                             <artifactSet>
                                 <includes combine.children="append">

flink-kubernetes-operator/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointTriggerRequestBody.java

@@ -18,6 +18,7 @@
 package org.apache.flink.kubernetes.operator.autoscaler;
 
 import org.apache.flink.autoscaler.tuning.ConfigChanges;
+import org.apache.flink.configuration.GlobalConfiguration;
 import org.apache.flink.configuration.MemorySize;
 import org.apache.flink.configuration.PipelineOptions;
 import org.apache.flink.configuration.TaskManagerOptions;
@@ -35,6 +36,9 @@ public class KubernetesScalingRealizerTest {
 
     @Test
     public void testApplyOverrides() {
+        // Required to keep the test config context on legacy Flink YAML converters.
+        GlobalConfiguration.setStandardYaml(false);
+
         KubernetesJobAutoScalerContext ctx =
                 TestingKubernetesAutoscalerUtils.createContext("test", null);
 

flink-kubernetes-operator/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/stop/StopWithSavepointRequestBody.java

@@ -136,7 +136,7 @@ public void testTemplateSpec() {
         assertEquals(1, podSpec.getContainers().size());
         assertEquals(TestUtils.SERVICE_ACCOUNT, podSpec.getServiceAccountName());
         // Config and secret volumes
-        assertEquals(3, podSpec.getVolumes().size());
+        assertEquals(4, podSpec.getVolumes().size());
 
         final Container mainContainer = podSpec.getContainers().get(0);
         assertEquals(Constants.MAIN_CONTAINER_NAME, mainContainer.getName());
@@ -184,7 +184,7 @@ public void testTemplateSpec() {
         assertEquals(
                 String.valueOf(TestUtils.JOB_MANAGER_MEMORY_MB), limits.get("memory").getAmount());
 
-        assertEquals(3, mainContainer.getVolumeMounts().size());
+        assertEquals(4, mainContainer.getVolumeMounts().size());
     }
 
     @Test

flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesScalingRealizerTest.java

@@ -83,7 +83,7 @@ under the License.
         <lombok.version>1.18.30</lombok.version>
         <commons-lang3.version>3.12.0</commons-lang3.version>
         <commons-io.version>2.11.0</commons-io.version>
-        <flink.version>1.18.1</flink.version>
+        <flink.version>1.19.1</flink.version>
 
         <slf4j.version>1.7.36</slf4j.version>
         <log4j.version>2.17.1</log4j.version>