This is an automated email from the ASF dual-hosted git repository.
diwu 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 61372f3 [Improve] Support flink1.19 (#345)
61372f3 is described below
commit 61372f3608870041d11877082316fc312eefd566
Author: wudi <676366...@qq.com>
AuthorDate: Tue Mar 19 14:09:13 2024 +0800
[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 298894f..086db93 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 8b78fb7..ebd9cbb 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 1c67f2b..0c807d3 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:
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
