Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Dockerfile
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
6 changes: 3 additions & 3 deletions docs/config.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand All @@ -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]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ MongoDB CDC 连接器允许从 MongoDB 读取快照数据和增量数据。 本
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-mongodb-cdc</artifactId>
<!-- 请使用已发布的版本依赖,snapshot 版本的依赖需要本地自行编译。 -->
<version>3.2-SNAPSHOT</version>
<version>3.3-SNAPSHOT</version>
</dependency>
```

Expand Down
2 changes: 1 addition & 1 deletion docs/content.zh/docs/connectors/flink-sources/mysql-cdc.md
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ MySQL CDC 连接器允许从 MySQL 数据库读取快照数据和增量数据。
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-mysql-cdc</artifactId>
<!-- 请使用已发布的版本依赖,snapshot 版本的依赖需要本地自行编译。 -->
<version>3.2-SNAPSHOT</version>
<version>3.3-SNAPSHOT</version>
</dependency>
```

Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ limitations under the License.
</distributionManagement>

<properties>
<revision>3.2-SNAPSHOT</revision>
<revision>3.3-SNAPSHOT</revision>
<java.version>1.8</java.version>
<scala.binary.version>2.12</scala.binary.version>
<maven.compiler.source>${java.version}</maven.compiler.source>
Expand Down
2 changes: 1 addition & 1 deletion tools/mig-test/datastream/compile_jobs.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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}"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,13 +22,13 @@ limitations under the License.

<groupId>org.apache.flink</groupId>
<artifactId>datastream-job</artifactId>
<version>3.2-SNAPSHOT</version>
<version>3.3-SNAPSHOT</version>
<packaging>jar</packaging>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.18.1</flink.version>
<flink.cdc.version>3.2-SNAPSHOT</flink.cdc.version>
<flink.cdc.version>3.3-SNAPSHOT</flink.cdc.version>
<debezium.version>1.9.7.Final</debezium.version>
<scala.binary.version>2.12</scala.binary.version>
<slf4j.version>2.0.13</slf4j.version>
Expand Down
2 changes: 1 addition & 1 deletion tools/mig-test/datastream/run_migration_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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 = []

Expand Down
6 changes: 3 additions & 3 deletions tools/mig-test/prepare_libs.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -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
Expand Down Expand Up @@ -64,7 +64,7 @@
}
}.freeze

HEAD_VERSION = '3.2-SNAPSHOT'
HEAD_VERSION = '3.3-SNAPSHOT'

def download_or_get(link)
`mkdir -p cache`
Expand Down
2 changes: 1 addition & 1 deletion tools/mig-test/run_migration_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -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 = []
Expand Down