This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 70fd0cee7f [e2e] upgrade the flink-sql-connector-kafka version (#4881)
70fd0cee7f is described below
commit 70fd0cee7febef57360cd4a3c253bfc84d7073ee
Author: yangjf2019 <[email protected]>
AuthorDate: Fri Jan 10 19:07:27 2025 +0800
[e2e] upgrade the flink-sql-connector-kafka version (#4881)
---
paimon-e2e-tests/pom.xml | 2 ++
pom.xml | 3 +--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/paimon-e2e-tests/pom.xml b/paimon-e2e-tests/pom.xml
index 025b15a8bc..70f23e36cd 100644
--- a/paimon-e2e-tests/pom.xml
+++ b/paimon-e2e-tests/pom.xml
@@ -297,6 +297,7 @@ under the License.
<properties>
<test.flink.main.version>1.19</test.flink.main.version>
<test.flink.version>1.19.1</test.flink.version>
+
<test.flink.connector.kafka.version>3.2.0-${test.flink.main.version}</test.flink.connector.kafka.version>
<flink.sql.connector.hive>flink-sql-connector-hive-2.3.9_${scala.binary.version}</flink.sql.connector.hive>
</properties>
</profile>
@@ -306,6 +307,7 @@ under the License.
<properties>
<test.flink.main.version>1.18</test.flink.main.version>
<test.flink.version>1.18.1</test.flink.version>
+
<test.flink.connector.kafka.version>3.0.1-${test.flink.main.version}</test.flink.connector.kafka.version>
<flink.sql.connector.hive>flink-sql-connector-hive-2.3.9_${scala.binary.version}</flink.sql.connector.hive>
</properties>
</profile>
diff --git a/pom.xml b/pom.xml
index d55694cec7..d427e05df0 100644
--- a/pom.xml
+++ b/pom.xml
@@ -112,8 +112,7 @@ under the License.
<test.unit.pattern>**/*Test.*</test.unit.pattern>
<test.flink.main.version>1.20</test.flink.main.version>
<test.flink.version>1.20.0</test.flink.version>
- <!-- TODO upgrade after connector releases x-1.19 version -->
-
<test.flink.connector.kafka.version>3.0.1-1.18</test.flink.connector.kafka.version>
+
<test.flink.connector.kafka.version>3.4.0-1.20</test.flink.connector.kafka.version>
<test.mysql.connector.java.version>8.0.27</test.mysql.connector.java.version>
<!-- spark profile properties-->
