This is an automated email from the ASF dual-hosted git repository.
JNSimba pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 6e85eb3d [Feature] Support Flink 2.3 (#696)
6e85eb3d is described below
commit 6e85eb3daae2672c60d1a9ec24a741fb8ad93fbf
Author: wudi <[email protected]>
AuthorDate: Fri Sep 11 14:13:17 2026 +0800
[Feature] Support Flink 2.3 (#696)
---
.github/workflows/build-connector.yml | 10 +++++++++-
.github/workflows/run-e2ecase-flink2.yml | 6 +++---
.github/workflows/run-itcase-flink2.yml | 10 +++++-----
README.md | 1 +
flink-doris-connector/build.sh | 9 ++++++++-
flink-doris-connector/flink-doris-connector-flink2/pom.xml | 4 ++--
flink-doris-connector/pom.xml | 4 ++--
tools/releasing/deploy_staging_jars_for_jdk17.sh | 5 ++++-
8 files changed, 34 insertions(+), 15 deletions(-)
diff --git a/.github/workflows/build-connector.yml
b/.github/workflows/build-connector.yml
index 850034dc..b8e581e2 100644
--- a/.github/workflows/build-connector.yml
+++ b/.github/workflows/build-connector.yml
@@ -120,6 +120,14 @@ jobs:
-Dflink.version=2.2.0 \
-Dflink.major.version=2.2
+ - name: Build flink connector 2.3
+ run: |
+ cd flink-doris-connector && mvn clean package \
+ -pl flink-doris-connector-flink2 -am \
+ -Pflink2 \
+ -Dflink.version=2.3.0 \
+ -Dflink.major.version=2.3
+
build-flink2-jdk21:
name: "Build Flink 2.x on JDK 21"
runs-on: ubuntu-latest
@@ -141,7 +149,7 @@ jobs:
- name: Build Flink connectors
run: |
- for flink_major in 2.0 2.1 2.2; do
+ for flink_major in 2.0 2.1 2.2 2.3; do
mvn clean package \
-pl flink-doris-connector-flink2 -am \
-Pflink2 \
diff --git a/.github/workflows/run-e2ecase-flink2.yml
b/.github/workflows/run-e2ecase-flink2.yml
index 18c7f33d..1cace678 100644
--- a/.github/workflows/run-e2ecase-flink2.yml
+++ b/.github/workflows/run-e2ecase-flink2.yml
@@ -26,7 +26,7 @@ permissions:
jobs:
build-extension:
- name: "Run E2ECases (Flink 2.2, JDK ${{ matrix.java }})"
+ name: "Run E2ECases (Flink 2.3, JDK ${{ matrix.java }})"
runs-on: ubuntu-latest
timeout-minutes: 60
strategy:
@@ -58,8 +58,8 @@ jobs:
-Pflink2 -pl flink-doris-connector-it -am \
-DfailIfNoTests=false \
-Dtest="*E2ECase" \
- -Dflink.version=2.2.0 \
- -Dflink.major.version=2.2 \
+ -Dflink.version=2.3.0 \
+ -Dflink.major.version=2.3 \
-Dimage="jnsimba/doris-all-in-one:4.1.3"
- name: Verify Doris-to-Doris E2E report
diff --git a/.github/workflows/run-itcase-flink2.yml
b/.github/workflows/run-itcase-flink2.yml
index dfb61020..116989bf 100644
--- a/.github/workflows/run-itcase-flink2.yml
+++ b/.github/workflows/run-itcase-flink2.yml
@@ -26,7 +26,7 @@ permissions:
jobs:
build-extension:
- name: "Run ITCases"
+ name: "Run ITCases (Flink 2.3, JDK 17)"
runs-on: ubuntu-latest
defaults:
run:
@@ -52,8 +52,8 @@ jobs:
-Pflink2 -pl flink-doris-connector-it -am \
-DfailIfNoTests=false \
-Dtest="*ITCase" \
- -Dflink.version=2.2.0 \
- -Dflink.major.version=2.2 \
+ -Dflink.version=2.3.0 \
+ -Dflink.major.version=2.3 \
-Dimage="jnsimba/doris-all-in-one:4.1.3"
- name: Verify sensitive ITCase reports
@@ -74,8 +74,8 @@ jobs:
fail-fast: false
matrix:
include:
- - flink-version: 2.2.0
- flink-major: '2.2'
+ - flink-version: 2.3.0
+ flink-major: '2.3'
defaults:
run:
shell: bash
diff --git a/README.md b/README.md
index e9e2159c..3444f3e0 100644
--- a/README.md
+++ b/README.md
@@ -37,6 +37,7 @@ Flink Doris Connector supports the following Flink versions:
| 2.0.x | JDK 17 |
| 2.1.x | JDK 17; JDK 21 (experimental) |
| 2.2.x | JDK 17; JDK 21 (experimental) |
+| 2.3.x | JDK 17; JDK 21 (experimental) |
Flink 2.x artifacts are compiled with Java 17 (`--release 17`, classfile major
version 61) and can be built with JDK 17 or JDK 21. JDK 21 runtime
compatibility is experimental for the Flink versions listed above; JDK 17
remains the recommended runtime.
diff --git a/flink-doris-connector/build.sh b/flink-doris-connector/build.sh
index ade88b9d..b0ecf3f0 100755
--- a/flink-doris-connector/build.sh
+++ b/flink-doris-connector/build.sh
@@ -115,7 +115,7 @@ selectFlink() {
echo 'Flink-Doris-Connector supports multiple versions of flink. Which
version do you need ?'
echo ' [Flink 1.x requires JDK 8]'
echo ' [Flink 2.x builds require JDK 17 or 21; artifacts target Java 17]'
- select flink in "1.15.x" "1.16.x" "1.17.x" "1.18.x" "1.19.x" "1.20.x"
"2.0.x" "2.1.x" "2.2.x"
+ select flink in "1.15.x" "1.16.x" "1.17.x" "1.18.x" "1.19.x" "1.20.x"
"2.0.x" "2.1.x" "2.2.x" "2.3.x"
do
case $flink in
"1.15.x")
@@ -145,6 +145,9 @@ selectFlink() {
"2.2.x")
return 9
;;
+ "2.3.x")
+ return 10
+ ;;
*)
echo "invalid selected, exit.."
exit 1
@@ -184,6 +187,10 @@ elif [ ${flinkVer} -eq 9 ]; then
FLINK_VERSION="2.2.0"
FLINK_MODULE="flink-doris-connector-flink2"
FLINK_PROFILE="flink2"
+elif [ ${flinkVer} -eq 10 ]; then
+ FLINK_VERSION="2.3.0"
+ FLINK_MODULE="flink-doris-connector-flink2"
+ FLINK_PROFILE="flink2"
fi
# extract major version:
diff --git a/flink-doris-connector/flink-doris-connector-flink2/pom.xml
b/flink-doris-connector/flink-doris-connector-flink2/pom.xml
index 80a3b789..54c08860 100644
--- a/flink-doris-connector/flink-doris-connector-flink2/pom.xml
+++ b/flink-doris-connector/flink-doris-connector-flink2/pom.xml
@@ -32,8 +32,8 @@ under the License.
<description>Flink Doris Connector for Flink 2.0+ </description>
<properties>
- <flink.version>2.2.0</flink.version>
- <flink.major.version>2.2</flink.major.version>
+ <flink.version>2.3.0</flink.version>
+ <flink.major.version>2.3</flink.major.version>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
</properties>
diff --git a/flink-doris-connector/pom.xml b/flink-doris-connector/pom.xml
index 03bdfccb..73517416 100644
--- a/flink-doris-connector/pom.xml
+++ b/flink-doris-connector/pom.xml
@@ -488,8 +488,8 @@ under the License.
<profile>
<id>flink2</id>
<properties>
- <flink.version>2.2.0</flink.version>
- <flink.major.version>2.2</flink.major.version>
+ <flink.version>2.3.0</flink.version>
+ <flink.major.version>2.3</flink.major.version>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<maven.compiler.release>17</maven.compiler.release>
diff --git a/tools/releasing/deploy_staging_jars_for_jdk17.sh
b/tools/releasing/deploy_staging_jars_for_jdk17.sh
index 4cdf10a7..9ccd13b4 100644
--- a/tools/releasing/deploy_staging_jars_for_jdk17.sh
+++ b/tools/releasing/deploy_staging_jars_for_jdk17.sh
@@ -61,5 +61,8 @@ ${MVN} clean deploy -Papache-release
-DretryFailedDeploymentCount=10 -pl flink-d
echo "Deploying Flink 2.2..."
${MVN} clean deploy -Papache-release -DretryFailedDeploymentCount=10 -pl
flink-doris-connector-flink2 -am -Pflink2 -Dflink.version=2.2.0
-Dflink.major.version=2.2 -DskipTests=true
+echo "Deploying Flink 2.3..."
+${MVN} clean deploy -Papache-release -DretryFailedDeploymentCount=10 -pl
flink-doris-connector-flink2 -am -Pflink2 -Dflink.version=2.3.0
-Dflink.major.version=2.3 -DskipTests=true
+
echo "Deploy jar with jdk17 finished."
-cd ${CURR_DIR}
\ No newline at end of file
+cd ${CURR_DIR}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
