You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2026/03/24 12:41:42 UTC
(flink-cdc) branch release-3.6 updated (5e512cb4b -> e06639a62)
This is an automated email from the ASF dual-hosted git repository.
kunni pushed a change to branch release-3.6
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
discard 5e512cb4b [hotfix] Fix e2e test error for StarRocks Pipeline.
omit 7dceb2a4c [hotfix] Fix compile error.
omit ab52ccf4e [FLINK-38729] Add flink-cdc-flink*-compat to output t jar for source connector.
omit 21ec4aeb5 [docs] Update config.toml.
add 3d405fba1 [FLINK-39295] Update MySQL docs to reflect MySQL 8.4+ support (#4331)
add 283edb650 [FLINK-39297][doc] Update pipeline connectors overview for Flink CDC 3.6.0 (#4329)
add 723615b66 [FLINK-39312][pipeline][hudi] Fix Hudi connector packaging to include flink-metrics-dropwizard dependency. (#4332)
add 08f3fb88f [FLINK-39289][paimon] Supports executing TRUNCATE schema change events on tables with deletion-vectors.enabled:true set (#4327)
new 685e6ebb1 [docs] Update config.toml.
new 0b06dc12a [FLINK-38729] Add flink-cdc-flink*-compat to output t jar for source connector.
new f7a6ab1da [hotfix] Fix compile error.
new e06639a62 [hotfix] Fix e2e test error for StarRocks Pipeline.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5e512cb4b)
\
N -- N -- N refs/heads/release-3.6 (e06639a62)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../docs/connectors/flink-sources/mysql-cdc.md | 16 +++++-
.../docs/connectors/flink-sources/overview.md | 64 +++++++++++-----------
.../connectors/pipeline-connectors/overview.md | 44 ++++++++-------
.../docs/connectors/flink-sources/mysql-cdc.md | 16 +++++-
.../docs/connectors/flink-sources/overview.md | 64 +++++++++++-----------
.../connectors/pipeline-connectors/overview.md | 44 ++++++++-------
.../flink-cdc-pipeline-connector-hudi/pom.xml | 1 -
.../paimon/sink/PaimonMetadataApplier.java | 5 --
.../paimon/sink/v2/PaimonSinkITCase.java | 15 +----
.../cdc/pipeline/tests/MySqlToHudiE2eITCase.java | 5 --
10 files changed, 142 insertions(+), 132 deletions(-)
(flink-cdc) 02/04: [FLINK-38729] Add flink-cdc-flink*-compat to output t jar for source connector.
Posted by ku...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch release-3.6
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 0b06dc12acab397a111b0f5dbb86858ab60285c4
Author: lvyanquan <lv...@alibaba-inc.com>
AuthorDate: Sat Mar 21 10:42:54 2026 +0800
[FLINK-38729] Add flink-cdc-flink*-compat to output t jar for source connector.
---
.../flink-sql-connector-mongodb-cdc/pom.xml | 1 +
.../flink-sql-connector-mysql-cdc/pom.xml | 1 +
.../flink-sql-connector-oceanbase-cdc/pom.xml | 1 +
.../flink-sql-connector-oracle-cdc/pom.xml | 1 +
.../flink-sql-connector-postgres-cdc/pom.xml | 1 +
.../flink-sql-connector-sqlserver-cdc/pom.xml | 1 +
.../flink-sql-connector-tidb-cdc/pom.xml | 1 +
.../flink-cdc-source-connectors/pom.xml | 28 ++++++++++++++++++++++
8 files changed, 35 insertions(+)
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/pom.xml
index f4ba11058..19e0e1141 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/pom.xml
@@ -59,6 +59,7 @@ limitations under the License.
<include>org.apache.flink:flink-cdc-common</include>
<include>org.apache.flink:flink-connector-debezium</include>
<include>org.apache.flink:flink-connector-mongodb-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>org.mongodb.kafka:mongo-kafka-connect</include>
<include>org.mongodb:mongodb-driver-sync</include>
<include>org.mongodb:mongodb-driver-core</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/pom.xml
index 30eaf5287..eb8aef15f 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/pom.xml
@@ -60,6 +60,7 @@ limitations under the License.
<include>org.apache.flink:flink-cdc-common</include>
<include>org.apache.flink:flink-connector-debezium</include>
<include>org.apache.flink:flink-connector-mysql-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>org.antlr:antlr4-runtime</include>
<include>org.apache.kafka:*</include>
<include>com.zendesk:mysql-binlog-connector-java</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/pom.xml
index 3774acf5f..912d8db66 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/pom.xml
@@ -66,6 +66,7 @@ limitations under the License.
<include>org.apache.flink:flink-cdc-common</include>
<include>org.apache.flink:flink-connector-debezium</include>
<include>org.apache.flink:flink-connector-mysql-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>org.antlr:antlr4-runtime</include>
<include>org.apache.kafka:*</include>
<include>com.zendesk:mysql-binlog-connector-java</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/pom.xml
index 933799cd3..696af55cb 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/pom.xml
@@ -61,6 +61,7 @@ limitations under the License.
<include>org.apache.flink:flink-cdc-base</include>
<include>org.apache.flink:flink-cdc-common</include>
<include>org.apache.flink:flink-connector-oracle-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>org.antlr:antlr4-runtime</include>
<include>com.github.jsqlparser:jsqlparser</include>
<include>org.apache.kafka:*</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/pom.xml
index 953acfa23..93c3a82f0 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/pom.xml
@@ -60,6 +60,7 @@ limitations under the License.
<include>org.apache.flink:flink-cdc-common</include>
<include>org.apache.flink:flink-connector-debezium</include>
<include>org.apache.flink:flink-connector-postgres-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>com.zaxxer:HikariCP</include>
<include>com.google.protobuf:protobuf-java</include>
<include>com.google.guava:*</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/pom.xml
index d086d4f1a..21d96a72c 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/pom.xml
@@ -60,6 +60,7 @@ limitations under the License.
<include>org.apache.flink:flink-cdc-base</include>
<include>org.apache.flink:flink-cdc-common</include>
<include>org.apache.flink:flink-connector-sqlserver-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>com.microsoft.sqlserver:*</include>
<include>org.apache.kafka:*</include>
<include>com.fasterxml.*:*</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml
index a32614e7f..bf8c3a659 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml
@@ -54,6 +54,7 @@ limitations under the License.
<includes>
<include>org.apache.flink:flink-connector-debezium</include>
<include>org.apache.flink:flink-connector-tidb-cdc</include>
+ <include>org.apache.flink:flink-cdc-flink*-compat</include>
<include>org.tikv:tikv-client-java</include>
<include>com.google.protobuf:*</include>
<include>io.grpc:*</include>
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/pom.xml b/flink-cdc-connect/flink-cdc-source-connectors/pom.xml
index 13c9afa04..cd1a63a81 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/pom.xml
+++ b/flink-cdc-connect/flink-cdc-source-connectors/pom.xml
@@ -76,4 +76,32 @@ limitations under the License.
</dependency>
</dependencies>
+ <profiles>
+ <!-- Default profile: use flink-cdc-flink1-compat -->
+ <profile>
+ <id>flink1</id>
+ <activation>
+ <activeByDefault>true</activeByDefault>
+ </activation>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-cdc-flink1-compat</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </profile>
+ <!-- Flink 2 profile: use flink-cdc-flink2-compat -->
+ <profile>
+ <id>flink2</id>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-cdc-flink2-compat</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ </profile>
+ </profiles>
+
</project>
\ No newline at end of file
(flink-cdc) 04/04: [hotfix] Fix e2e test error for StarRocks Pipeline.
Posted by ku...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch release-3.6
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit e06639a62d98c233d25bdc689b975dcbd186bb24
Author: lvyanquan <lv...@alibaba-inc.com>
AuthorDate: Sat Mar 21 14:21:44 2026 +0800
[hotfix] Fix e2e test error for StarRocks Pipeline.
---
.../main/java/org/apache/flink/api/connector/sink2/StatefulSink.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java b/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java
index 1298f9e6b..391d12de7 100644
--- a/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java
+++ b/flink-cdc-flink2-compat/src/main/java/org/apache/flink/api/connector/sink2/StatefulSink.java
@@ -35,6 +35,8 @@ import java.util.Collection;
public interface StatefulSink<InputT, WriterStateT>
extends Sink<InputT>, SupportsWriterState<InputT, WriterStateT> {
+ SinkWriter<InputT> createWriter(InitContext initContext) throws IOException;
+
@Override
default SinkWriter<InputT> createWriter(WriterInitContext writerInitContext)
throws IOException {
(flink-cdc) 01/04: [docs] Update config.toml.
Posted by ku...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch release-3.6
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 685e6ebb199469a5b66f42998b4d5f8b40723128
Author: lvyanquan <lv...@alibaba-inc.com>
AuthorDate: Sat Mar 21 09:30:53 2026 +0800
[docs] Update config.toml.
---
docs/config.toml | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/docs/config.toml b/docs/config.toml
index 9b653bca1..2d7fc56b8 100644
--- a/docs/config.toml
+++ b/docs/config.toml
@@ -14,7 +14,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-baseURL = '//nightlies.apache.org/flink/flink-cdc-docs-master'
+baseURL = '//nightlies.apache.org/flink/flink-cdc-docs-release-3.6'
languageCode = 'en-us'
title = 'Apache Flink CDC'
enableGitInfo = false
@@ -34,14 +34,14 @@ pygmentsUseClasses = true
# where we change the version for the complete docs when forking of a release
# branch etc.
# The full version string as referenced in Maven (e.g. 1.2.1)
- Version = "3.6-SNAPSHOT"
+ Version = "3.6.0"
# For stable releases, leave the bugfix version out (e.g. 1.2). For snapshot
# release this should be the same as the regular version
- VersionTitle = "3.6-SNAPSHOT"
+ VersionTitle = "3.6"
# The branch for this version of Apache Flink CDC
- Branch = "master"
+ Branch = "release-3.6"
# The GitHub repository for Apache Flink CDC
Repo = "//github.com/apache/flink-cdc"
@@ -54,7 +54,7 @@ pygmentsUseClasses = true
# of the menu
MenuLinks = [
["Project Homepage", "//flink.apache.org"],
- ["JavaDocs", "//nightlies.apache.org/flink/flink-cdc-docs-master/api/java/"],
+ ["JavaDocs", "//nightlies.apache.org/flink/flink-cdc-docs-release-3.6/api/java/"],
]
PreviousDocs = [
(flink-cdc) 03/04: [hotfix] Fix compile error.
Posted by ku...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch release-3.6
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit f7a6ab1da9a254014d05441fc093c0de1bb9ddde
Author: lvyanquan <lv...@alibaba-inc.com>
AuthorDate: Sat Mar 21 12:00:35 2026 +0800
[hotfix] Fix compile error.
---
flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
index 704fdf606..a0f0cc823 100644
--- a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
+++ b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
@@ -172,7 +172,7 @@ limitations under the License.
</dependency>
<dependency>
<groupId>org.apache.paimon</groupId>
- <artifactId>paimon-flink-${flink.major.version}</artifactId>
+ <artifactId>paimon-flink-${paimon.flink.major.version}</artifactId>
<version>${paimon.version}</version>
<scope>test</scope>
</dependency>