From b83d8c6bfd7ee75fe0279b59b41de6bf310b577c Mon Sep 17 00:00:00 2001
From: Marvin Froeder <marvin@datasqrl.com>
Date: Tue, 25 Mar 2025 14:18:31 -0300
Subject: [PATCH] Add support to flink 2.0

Signed-off-by: Marvin Froeder <marvin@datasqrl.com>
---
 .github/workflows/delete-pr-images.yml | 2 +-
 .github/workflows/uber-jar.yml         | 2 +-
 pom.xml                                | 5 ++---
 3 files changed, 4 insertions(+), 5 deletions(-)

diff --git a/.github/workflows/delete-pr-images.yml b/.github/workflows/delete-pr-images.yml
index bfe751e..9f1b745 100644
--- a/.github/workflows/delete-pr-images.yml
+++ b/.github/workflows/delete-pr-images.yml
@@ -10,7 +10,7 @@ jobs:
 
     strategy:
       matrix:
-        FLINK_PROFILE: [flink-1.19, flink-1.20]
+        FLINK_PROFILE: [flink-1.19, flink-1.20, flink-2.0]
 
     steps:
       - name: Delete GHCR image via GitHub REST API
diff --git a/.github/workflows/uber-jar.yml b/.github/workflows/uber-jar.yml
index 242ac41..e8e1e09 100644
--- a/.github/workflows/uber-jar.yml
+++ b/.github/workflows/uber-jar.yml
@@ -20,7 +20,7 @@ jobs:
 
     strategy:
       matrix:
-        FLINK_PROFILE: [flink-1.19, flink-1.20]
+        FLINK_PROFILE: [flink-1.19, flink-1.20, flink-2.0]
 
     env:
       VERSION: ${{ github.event_name == 'release' && github.event.action == 'created' && github.ref_name || 'snapshot' }}
diff --git a/pom.xml b/pom.xml
index 264cc62..c56c6f4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -47,7 +47,6 @@
     <log4j.version>2.24.3</log4j.version>
     <feign.version>13.5</feign.version>
     <picocli.version>4.7.6</picocli.version>
-    <flink.version>1.19.2</flink.version>
     <postgres.version>42.7.5</postgres.version>
     <testcontainers.version>1.20.6</testcontainers.version>
   </properties>
@@ -484,10 +483,10 @@
     <profile>
       <id>flink-2.0</id>
       <properties>
-        <flink.version>2.0-preview1</flink.version>
+        <flink.version>2.0.0</flink.version>
         <jdbc.version>3.2.0-1.19</jdbc.version>
         <kafka.version>3.2.0-1.19</kafka.version>
-        <flink-base-image>2.0-preview1-scala_2.12-java17</flink-base-image>
+        <flink-base-image>2.0.0-scala_2.12-java17</flink-base-image>
       </properties>
     </profile>
     <profile>