diff --git a/Dockerfile b/Dockerfile index d0deb5a29a1..ea5da86988d 100644 --- a/Dockerfile +++ b/Dockerfile @@ -17,7 +17,7 @@ FROM flink -ARG FLINK_CDC_VERSION=3.2-SNAPSHOT +ARG FLINK_CDC_VERSION=3.3-SNAPSHOT ARG PIPELINE_DEFINITION_FILE RUN mkdir -p /opt/flink-cdc diff --git a/docs/config.toml b/docs/config.toml index 9b1acfc09da..8ed68a53fb7 100644 --- a/docs/config.toml +++ b/docs/config.toml @@ -34,11 +34,11 @@ pygmentsUseClasses = true # 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.2-SNAPSHOT" + Version = "3.3-SNAPSHOT" # 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.2-SNAPSHOT" + VersionTitle = "3.3-SNAPSHOT" # The branch for this version of Apache Flink CDC Branch = "master" @@ -58,8 +58,8 @@ pygmentsUseClasses = true ] PreviousDocs = [ + ["3.2", "https://nightlies.apache.org/flink/flink-cdc-docs-release-3.2"], ["3.1", "https://nightlies.apache.org/flink/flink-cdc-docs-release-3.1"], - ["3.0", "https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0"], ] [markup] diff --git a/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md index 1dcb72e7588..83103c9218b 100644 --- a/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md +++ b/docs/content.zh/docs/connectors/flink-sources/mongodb-cdc.md @@ -39,7 +39,7 @@ MongoDB CDC 连接器允许从 MongoDB 读取快照数据和增量数据。 本 org.apache.flink flink-connector-mongodb-cdc - 3.2-SNAPSHOT + 3.3-SNAPSHOT ``` diff --git a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md index 3a2f2a6a664..e1c7b2937fb 100644 --- a/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md +++ b/docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md @@ -46,7 +46,7 @@ MySQL CDC 连接器允许从 MySQL 数据库读取快照数据和增量数据。 org.apache.flink flink-connector-mysql-cdc - 3.2-SNAPSHOT + 3.3-SNAPSHOT ``` diff --git a/pom.xml b/pom.xml index 9955a6c56cc..1fbe4947c7e 100644 --- a/pom.xml +++ b/pom.xml @@ -63,7 +63,7 @@ limitations under the License. - 3.2-SNAPSHOT + 3.3-SNAPSHOT 1.8 2.12 ${java.version} diff --git a/tools/mig-test/datastream/compile_jobs.rb b/tools/mig-test/datastream/compile_jobs.rb index 579c0ba6019..68a5d8e824c 100644 --- a/tools/mig-test/datastream/compile_jobs.rb +++ b/tools/mig-test/datastream/compile_jobs.rb @@ -16,7 +16,7 @@ # See the License for the specific language governing permissions and # limitations under the License. -JOB_VERSIONS = %w[2.4.2 3.0.0 3.0.1 3.1.0 3.1.1 3.2-SNAPSHOT] +JOB_VERSIONS = %w[2.4.2 3.0.0 3.0.1 3.1.0 3.1.1 3.3-SNAPSHOT] JOB_VERSIONS.each do |version| puts "Compiling DataStream job for CDC #{version}" diff --git a/tools/mig-test/datastream/datastream-3.2-SNAPSHOT/.gitignore b/tools/mig-test/datastream/datastream-3.3-SNAPSHOT/.gitignore similarity index 100% rename from tools/mig-test/datastream/datastream-3.2-SNAPSHOT/.gitignore rename to tools/mig-test/datastream/datastream-3.3-SNAPSHOT/.gitignore diff --git a/tools/mig-test/datastream/datastream-3.2-SNAPSHOT/pom.xml b/tools/mig-test/datastream/datastream-3.3-SNAPSHOT/pom.xml similarity index 98% rename from tools/mig-test/datastream/datastream-3.2-SNAPSHOT/pom.xml rename to tools/mig-test/datastream/datastream-3.3-SNAPSHOT/pom.xml index e9d9ceb8ad0..b67eb208232 100644 --- a/tools/mig-test/datastream/datastream-3.2-SNAPSHOT/pom.xml +++ b/tools/mig-test/datastream/datastream-3.3-SNAPSHOT/pom.xml @@ -22,13 +22,13 @@ limitations under the License. org.apache.flink datastream-job - 3.2-SNAPSHOT + 3.3-SNAPSHOT jar UTF-8 1.18.1 - 3.2-SNAPSHOT + 3.3-SNAPSHOT 1.9.7.Final 2.12 2.0.13 diff --git a/tools/mig-test/datastream/datastream-3.2-SNAPSHOT/src/main/java/DataStreamJob.java b/tools/mig-test/datastream/datastream-3.3-SNAPSHOT/src/main/java/DataStreamJob.java similarity index 100% rename from tools/mig-test/datastream/datastream-3.2-SNAPSHOT/src/main/java/DataStreamJob.java rename to tools/mig-test/datastream/datastream-3.3-SNAPSHOT/src/main/java/DataStreamJob.java diff --git a/tools/mig-test/datastream/run_migration_test.rb b/tools/mig-test/datastream/run_migration_test.rb index a02b79b5094..aa7408d6046 100644 --- a/tools/mig-test/datastream/run_migration_test.rb +++ b/tools/mig-test/datastream/run_migration_test.rb @@ -93,7 +93,7 @@ def test_migration(from_version, to_version) end end -version_list = %w[2.4.2 3.0.0 3.0.1 3.1.0 3.1.1 3.2-SNAPSHOT] +version_list = %w[2.4.2 3.0.0 3.0.1 3.1.0 3.1.1 3.3-SNAPSHOT] version_result = Hash.new('❓') @failures = [] diff --git a/tools/mig-test/prepare_libs.rb b/tools/mig-test/prepare_libs.rb index aefb8338c2a..58b17cb6976 100644 --- a/tools/mig-test/prepare_libs.rb +++ b/tools/mig-test/prepare_libs.rb @@ -23,7 +23,7 @@ RELEASED_VERSIONS = { '3.0.0': { - tar: 'https://github.com/ververica/flink-cdc-connectors/releases/download/release-3.0.0/flink-cdc-3.0.0-bin.tar.gz', + tar: 'https://github.com/apache/flink-cdc/releases/download/release-3.0.0/flink-cdc-3.0.0-bin.tar.gz', connectors: %w[ https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.0/flink-cdc-pipeline-connector-doris-3.0.0.jar https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.0/flink-cdc-pipeline-connector-mysql-3.0.0.jar @@ -32,7 +32,7 @@ ] }, '3.0.1': { - tar: 'https://github.com/ververica/flink-cdc-connectors/releases/download/release-3.0.1/flink-cdc-3.0.1-bin.tar.gz', + tar: 'https://github.com/apache/flink-cdc/releases/download/release-3.0.1/flink-cdc-3.0.1-bin.tar.gz', connectors: %w[ https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-doris/3.0.1/flink-cdc-pipeline-connector-doris-3.0.1.jar https://repo1.maven.org/maven2/com/ververica/flink-cdc-pipeline-connector-mysql/3.0.1/flink-cdc-pipeline-connector-mysql-3.0.1.jar @@ -64,7 +64,7 @@ } }.freeze -HEAD_VERSION = '3.2-SNAPSHOT' +HEAD_VERSION = '3.3-SNAPSHOT' def download_or_get(link) `mkdir -p cache` diff --git a/tools/mig-test/run_migration_test.rb b/tools/mig-test/run_migration_test.rb index 5bb31cf3083..d7c2fff284c 100644 --- a/tools/mig-test/run_migration_test.rb +++ b/tools/mig-test/run_migration_test.rb @@ -114,7 +114,7 @@ def test_migration(from_version, to_version) end end -version_list = %w[3.0.0 3.0.1 3.1.0 3.1.1 3.2-SNAPSHOT] +version_list = %w[3.0.0 3.0.1 3.1.0 3.1.1 3.3-SNAPSHOT] no_savepoint_versions = %w[3.0.0 3.0.1] version_result = Hash.new('❓') @failures = []