chore: Bump Flink version to 2.2.1 (#341)

Author: ferenc-csaky

CLAUDE.md

@@ -62,7 +62,7 @@ java -jar flink-sql-runner/target/flink-sql-runner.jar --sqlfile script.sql --ud
 ## Technology Stack
 
 - **Java 17** - Base language version
-- **Apache Flink 2.2.0** - Stream processing framework
+- **Apache Flink 2.2.1** - Stream processing framework
 - **Maven** - Build system
 - **Lombok** - Code generation
 - **PicoCLI** - Command line interface

flink-sql-runner/pom.xml

@@ -51,17 +51,9 @@
       <scope>provided</scope>
     </dependency>
 
-    <!-- TODO: Switch back to planner loader when PTF loading is patched upstream. -->
-    <!--    <dependency>-->
-    <!--      <groupId>org.apache.flink</groupId>-->
-    <!--      <artifactId>flink-table-planner-loader</artifactId>-->
-    <!--      <version>${flink.version}</version>-->
-    <!--      <scope>provided</scope>-->
-    <!--    </dependency>-->
-
     <dependency>
       <groupId>org.apache.flink</groupId>
-      <artifactId>flink-table-planner_2.12</artifactId>
+      <artifactId>flink-table-planner-loader</artifactId>
       <version>${flink.version}</version>
       <scope>provided</scope>
     </dependency>
@@ -521,26 +513,6 @@
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-dependency-plugin</artifactId>
         <executions>
-          <execution>
-            <id>unpack-flink-table-planner-without-rex-json-deser</id>
-            <goals>
-              <goal>unpack</goal>
-            </goals>
-            <phase>prepare-package</phase>
-            <configuration>
-              <artifactItems>
-                <artifactItem>
-                  <groupId>org.apache.flink</groupId>
-                  <artifactId>flink-table-planner_2.12</artifactId>
-                  <version>${flink.version}</version>
-                  <type>jar</type>
-                  <overWrite>true</overWrite>
-                  <outputDirectory>${project.build.directory}/flink-table-planner-temp</outputDirectory>
-                  <excludes>org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonDeserializer**</excludes>
-                </artifactItem>
-              </artifactItems>
-            </configuration>
-          </execution>
           <execution>
             <id>unpack-iceberg-aws-bundle-without-logging</id>
             <goals>
@@ -675,22 +647,6 @@
         <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-antrun-plugin</artifactId>
         <executions>
-          <execution>
-            <!-- Repackage flink-table-planner_2.12 and override RexNodeJsonDeserializer using antrun plugin -->
-            <id>repack-flink-table-planner</id>
-            <goals>
-              <goal>run</goal>
-            </goals>
-            <phase>prepare-package</phase>
-            <configuration>
-              <target>
-                <copy failonerror="true" todir="${project.build.directory}/flink-table-planner-temp/org/apache/flink/table/planner/plan/nodes/exec/serde">
-                  <fileset dir="${project.build.outputDirectory}/org/apache/flink/table/planner/plan/nodes/exec/serde" includes="RexNodeJsonDeserializer*.class"/>
-                </copy>
-                <jar basedir="${project.build.directory}/flink-table-planner-temp" destfile="${project.build.directory}/flink-table-planner_2.12-${flink.version}.jar"/>
-              </target>
-            </configuration>
-          </execution>
           <execution>
             <!-- Repackage iceberg-aws-bundle without SLF4J using antrun plugin -->
             <id>repack-iceberg-aws-bundle</id>

flink-sql-runner/src/main/docker/Dockerfile

@@ -46,7 +46,6 @@ RUN set -eu; \
     && rm -f /tmp/async-profiler.tar.gz \
     && rm -rf /var/lib/apt/lists/*
 
-COPY flink-table-planner_2.12-*.jar /opt/flink/lib
 COPY flink-s3-fs-hadoop-*.jar /opt/flink/lib
 COPY hadoop-common-*.jar /opt/flink/lib
 COPY hadoop-hdfs-client-*.jar /opt/flink/lib
@@ -58,8 +57,7 @@ COPY flink-sql-runner.uber.jar /opt/flink/lib/sql-runner.uber.jar
 COPY --chmod=755 sql-runner /opt/flink/bin/sql-runner
 COPY --chmod=755 entrypoint.sh /entrypoint.sh
 
-RUN rm -rf /opt/flink/lib/flink-table-planner-loader-*.jar \
-    && echo 'UEsDBBQACAgIAG2UllwAAAAAAAAAAAAAAAAUAAQATUVUQS1JTkYvTUFOSUZFU1QuTUb+ygAA803My0xLLS7RDUstKs7Mz7NSMNQz4HIuSk0sSU3Rdaq0UkjLyczL1i0uzNEtKs3LSy3i4gIAUEsHCL/cUjU2AAAANAAAAFBLAQIUABQACAgIAG2Ully/3FI1NgAAADQAAAAUAAQAAAAAAAAAAAAAAAAAAABNRVRBLUlORi9NQU5JRkVTVC5NRv7KAABQSwUGAAAAAAEAAQBGAAAAfAAAAAAA' | base64 -d > /opt/flink/noop.jar \
+RUN echo 'UEsDBBQACAgIAG2UllwAAAAAAAAAAAAAAAAUAAQATUVUQS1JTkYvTUFOSUZFU1QuTUb+ygAA803My0xLLS7RDUstKs7Mz7NSMNQz4HIuSk0sSU3Rdaq0UkjLyczL1i0uzNEtKs3LSy3i4gIAUEsHCL/cUjU2AAAANAAAAFBLAQIUABQACAgIAG2Ully/3FI1NgAAADQAAAAUAAQAAAAAAAAAAAAAAAAAAABNRVRBLUlORi9NQU5JRkVTVC5NRv7KAABQSwUGAAAAAAEAAQBGAAAAfAAAAAAA' | base64 -d > /opt/flink/noop.jar \
     && mkdir -p /opt/flink/hadoop-conf \
     && echo '<configuration><property><name>fs.s3a.aws.credentials.provider</name><value>com.amazonaws.auth.DefaultAWSCredentialsProviderChain</value></property></configuration>' > /opt/flink/hadoop-conf/core-site.xml \
     && chown -R flink:flink /opt/flink