From 61372f3608870041d11877082316fc312eefd566 Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Tue, 19 Mar 2024 14:09:13 +0800
Subject: [PATCH] [Improve] Support flink1.19 (#345)

---
 .github/workflows/build-connector.yml | 7 +++++++
 README.md                             | 2 +-
 flink-doris-connector/build.sh        | 7 ++++++-
 3 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/.github/workflows/build-connector.yml b/.github/workflows/build-connector.yml
index 298894f7d..086db9348 100644
--- a/.github/workflows/build-connector.yml
+++ b/.github/workflows/build-connector.yml
@@ -65,3 +65,10 @@ jobs:
           -Dflink.version=1.18.0 \
           -Dflink.minor.version=1.18 \
           -Dflink.python.id=flink-python
+
+    - name: Build flink connector 1.19
+      run: |
+        cd flink-doris-connector && mvn clean package \
+          -Dflink.version=1.19.0 \
+          -Dflink.minor.version=1.19 \
+          -Dflink.python.id=flink-python
\ No newline at end of file
diff --git a/README.md b/README.md
index 8b78fb742..ebd9cbb05 100644
--- a/README.md
+++ b/README.md
@@ -24,7 +24,7 @@ under the License.
 
 ## Flink Doris Connector
 
-Flink Doris Connector now support flink version from 1.11 to 1.18.
+Flink Doris Connector now support flink version from 1.11 to 1.19.
 
 If you wish to contribute or use a connector from flink 1.13 (and earlier), please use the [branch-for-flink-before-1.13](https://github.com/apache/doris-flink-connector/tree/branch-for-flink-before-1.13)
 
diff --git a/flink-doris-connector/build.sh b/flink-doris-connector/build.sh
index 1c67f2b24..0c807d3aa 100755
--- a/flink-doris-connector/build.sh
+++ b/flink-doris-connector/build.sh
@@ -116,7 +116,7 @@ fi
 
 selectFlink() {
   echo 'Flink-Doris-Connector supports multiple versions of flink. Which version do you need ?'
-  select flink in "1.15.x" "1.16.x" "1.17.x" "1.18.x"
+  select flink in "1.15.x" "1.16.x" "1.17.x" "1.18.x" "1.19.x"
   do
     case $flink in
       "1.15.x")
@@ -131,6 +131,9 @@ selectFlink() {
       "1.18.x")
         return 4
         ;;
+      "1.19.x")
+        return 5
+        ;;
       *)
         echo "invalid selected, exit.."
         exit 1
@@ -152,6 +155,8 @@ elif [ ${flinkVer} -eq 3 ]; then
     FLINK_VERSION="1.17.0"
 elif [ ${flinkVer} -eq 4 ]; then
     FLINK_VERSION="1.18.0"
+elif [ ${flinkVer} -eq 5 ]; then
+    FLINK_VERSION="1.19.0"
 fi
 
 # extract major version: