Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[FLINK-37364][build] Bump Flink 1.19 and 1.20 patch versions #3927

Merged
merged 1 commit into from
Mar 5, 2025
Merged

[FLINK-37364][build] Bump Flink 1.19 and 1.20 patch versions #3927

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
6 changes: 3 additions & 3 deletions .github/workflows/flink_cdc_ci.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -76,19 +76,19 @@ jobs:
uses: ./.github/workflows/flink_cdc_base.yml
with:
java-version: "[8]"
flink-version: "['1.19.1', '1.20.0']"
flink-version: "['1.19.2', '1.20.1']"
module: pipeline_e2e
parallelism: ${{ matrix.parallelism }}
source_e2e:
name: Source E2E Tests
uses: ./.github/workflows/flink_cdc_base.yml
with:
java-version: "[8]"
flink-version: "['1.19.1', '1.20.0']"
flink-version: "['1.19.2', '1.20.1']"
module: source_e2e
migration_test:
name: Migration Tests
uses: ./.github/workflows/flink_cdc_migration_test_base.yml
with:
java-version: "[8]"
flink-version: "['1.19.1', '1.20.0']"
flink-version: "['1.19.2', '1.20.1']"
6 changes: 3 additions & 3 deletions .github/workflows/flink_cdc_ci_nightly.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -65,19 +65,19 @@ jobs:
uses: ./.github/workflows/flink_cdc_base.yml
with:
java-version: "[11]"
flink-version: "['1.19.1', '1.20.0']"
flink-version: "['1.19.2', '1.20.1']"
module: pipeline_e2e
parallelism: ${{ matrix.parallelism }}
source_e2e:
name: Source E2E Tests
uses: ./.github/workflows/flink_cdc_base.yml
with:
java-version: "[11]"
flink-version: "['1.19.1', '1.20.0']"
flink-version: "['1.19.2', '1.20.1']"
module: source_e2e
migration_test:
name: Migration Tests
uses: ./.github/workflows/flink_cdc_migration_test_base.yml
with:
java-version: "[11]"
flink-version: "['1.19.1', '1.20.0']"
flink-version: "['1.19.2', '1.20.1']"
2 changes: 1 addition & 1 deletion .github/workflows/flink_cdc_migration_test_base.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ jobs:
fail-fast: false
matrix:
java-version: ${{ fromJSON(inputs.java-version) }}
flink-version: [ '1.19.1', '1.20.0' ]
flink-version: [ '1.19.2', '1.20.1' ]

steps:
- uses: actions/checkout@v4
Expand Down
4 changes: 2 additions & 2 deletions docs/content.zh/docs/get-started/quickstart/cdc-up-quickstart-guide.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,8 +73,8 @@ Commands:
🐿️ Which Flink version would you like to use? (Press ↑/↓ arrow to move and Enter to select)
1.17.2
1.18.1
1.19.1
‣ 1.20.0
1.19.2
‣ 1.20.1
```

Use the arrow keys to navigate and press Enter to select specified Flink and CDC version, source, and sink connectors.
Expand Down
8 changes: 4 additions & 4 deletions docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,11 +33,11 @@ under the License.
准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。

### 准备 Flink Standalone 集群
1. 下载 [Flink 1.19.1](https://archive.apache.org/dist/flink/flink-1.19.1/flink-1.19.1-bin-scala_2.12.tgz)，解压后得到 flink-1.19.1 目录。
使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.19.1 所在目录。
1. 下载 [Flink 1.20.1](https://archive.apache.org/dist/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz)，解压后得到 flink-1.20.1 目录。
使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.20.1 所在目录。

```shell
cd flink-1.19.1
cd flink-1.20.1
```

2. 通过在 conf/flink-conf.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
Expand Down Expand Up @@ -338,7 +338,7 @@ Flink CDC 提供了将源表的表结构/数据路由到其他表名的配置，
```shell
docker-compose down
```
在 Flink 所在目录 `flink-1.19.1` 下执行如下命令停止 Flink 集群：
在 Flink 所在目录 `flink-1.20.1` 下执行如下命令停止 Flink 集群：

```shell
./bin/stop-cluster.sh
Expand Down
6 changes: 3 additions & 3 deletions docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,11 +33,11 @@ under the License.
准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。

### 准备 Flink Standalone 集群
1. 下载 [Flink 1.19.1](https://archive.apache.org/dist/flink/flink-1.19.1/flink-1.19.1-bin-scala_2.12.tgz) ，解压后得到 flink-1.19.1 目录。
1. 下载 [Flink 1.20.1](https://archive.apache.org/dist/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz) ，解压后得到 flink-1.20.1 目录。
使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.18.0 所在目录。

```shell
cd flink-1.19.1
cd flink-1.20.1
```

2. 通过在 conf/flink-conf.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
Expand Down Expand Up @@ -306,7 +306,7 @@ Flink CDC 提供了将源表的表结构/数据路由到其他表名的配置，
docker-compose down
```

在 Flink 所在目录 `flink-1.19.1` 下执行如下命令停止 Flink 集群：
在 Flink 所在目录 `flink-1.20.1` 下执行如下命令停止 Flink 集群：

```shell
./bin/stop-cluster.sh
Expand Down
4 changes: 2 additions & 2 deletions docs/content/docs/get-started/quickstart/cdc-up-quickstart-guide.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -73,8 +73,8 @@ Commands:
🐿️ Which Flink version would you like to use? (Press ↑/↓ arrow to move and Enter to select)
1.17.2
1.18.1
1.19.1
‣ 1.20.0
1.19.2
‣ 1.20.1
```

Use the arrow keys to navigate and press Enter to select specified Flink and CDC version, source, and sink connectors.
Expand Down
8 changes: 4 additions & 4 deletions docs/content/docs/get-started/quickstart/mysql-to-doris.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,11 @@ without a single line of Java/Scala code or IDE installation.
Prepare a Linux or MacOS computer with Docker installed.

### Prepare Flink Standalone cluster
1. Download [Flink 1.19.1](https://archive.apache.org/dist/flink/flink-1.19.1/flink-1.19.1-bin-scala_2.12.tgz) ，unzip and get flink-1.19.1 directory.
Use the following command to navigate to the Flink directory and set FLINK_HOME to the directory where flink-1.19.1 is located.
1. Download [Flink 1.20.1](https://archive.apache.org/dist/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz) ，unzip and get flink-1.20.1 directory.
Use the following command to navigate to the Flink directory and set FLINK_HOME to the directory where flink-1.20.1 is located.

```shell
cd flink-1.19.1
cd flink-1.20.1
```

2. Enable checkpointing by appending the following parameters to the conf/flink-conf.yaml configuration file to perform a checkpoint every 3 seconds.
Expand Down Expand Up @@ -343,7 +343,7 @@ After finishing the tutorial, run the following command to stop all containers i
```shell
docker-compose down
```
Run the following command to stop the Flink cluster in the directory of Flink `flink-1.19.1`:
Run the following command to stop the Flink cluster in the directory of Flink `flink-1.20.1`:

```shell
./bin/stop-cluster.sh
Expand Down
8 changes: 4 additions & 4 deletions docs/content/docs/get-started/quickstart/mysql-to-starrocks.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,11 @@ without a single line of Java/Scala code or IDE installation.
Prepare a Linux or MacOS computer with Docker installed.

### Prepare Flink Standalone cluster
1. Download [Flink 1.19.1](https://archive.apache.org/dist/flink/flink-1.19.1/flink-1.19.1-bin-scala_2.12.tgz) ，unzip and get flink-1.19.1 directory.
Use the following command to navigate to the Flink directory and set FLINK_HOME to the directory where flink-1.19.1 is located.
1. Download [Flink 1.20.1](https://archive.apache.org/dist/flink/flink-1.20.1/flink-1.20.1-bin-scala_2.12.tgz) ，unzip and get flink-1.20.1 directory.
Use the following command to navigate to the Flink directory and set FLINK_HOME to the directory where flink-1.20.1 is located.

```shell
cd flink-1.19.1
cd flink-1.20.1
```

2. Enable checkpointing by appending the following parameters to the conf/flink-conf.yaml configuration file to perform a checkpoint every 3 seconds.
Expand Down Expand Up @@ -310,7 +310,7 @@ After finishing the tutorial, run the following command to stop all containers i
docker-compose down
```

Run the following command to stop the Flink cluster in the directory of Flink `flink-1.19.1`:
Run the following command to stop the Flink cluster in the directory of Flink `flink-1.20.1`:

```shell
./bin/stop-cluster.sh
Expand Down
4 changes: 2 additions & 2 deletions flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@ limitations under the License.
<artifactId>flink-cdc-pipeline-e2e-tests</artifactId>

<properties>
<flink-1.19>1.19.1</flink-1.19>
<flink-1.20>1.20.0</flink-1.20>
<flink-1.19>1.19.2</flink-1.19>
<flink-1.20>1.20.1</flink-1.20>
<flink-major-1.19>1.19</flink-major-1.19>
<flink-major-1.20>1.20</flink-major-1.20>
<mysql.driver.version>8.0.27</mysql.driver.version>
Expand Down
2 changes: 1 addition & 1 deletion ...ests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ public static List<String> getFlinkVersion() {
if (flinkVersion != null) {
return Collections.singletonList(flinkVersion);
} else {
return Arrays.asList("1.19.1", "1.20.0");
return Arrays.asList("1.19.2", "1.20.1");
}
}

Expand Down
4 changes: 2 additions & 2 deletions flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@ limitations under the License.
<artifactId>flink-cdc-source-e2e-tests</artifactId>

<properties>
<flink-1.19>1.19.1</flink-1.19>
<flink-1.20>1.20.0</flink-1.20>
<flink-1.19>1.19.2</flink-1.19>
<flink-1.20>1.20.1</flink-1.20>
<jdbc.version-1.19>3.2.0-1.19</jdbc.version-1.19>
<jdbc.version-1.20>3.2.0-1.19</jdbc.version-1.20>
<mysql.driver.version>8.0.27</mysql.driver.version>
Expand Down
2 changes: 1 addition & 1 deletion .../test/java/org/apache/flink/cdc/connectors/tests/utils/FlinkContainerTestEnvironment.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ public static List<String> getFlinkVersion() {
if (flinkVersion != null) {
return Collections.singletonList(flinkVersion);
} else {
return Arrays.asList("1.19.1", "1.20.0");
return Arrays.asList("1.19.2", "1.20.1");
}
}

Expand Down
2 changes: 1 addition & 1 deletion pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ limitations under the License.
<flink.reuseForks>true</flink.reuseForks>

<!-- dependencies versions -->
<flink.version>1.20.0</flink.version>
<flink.version>1.20.1</flink.version>
<flink.major.version>1.20</flink.major.version>
<flink.shaded.version>17.0</flink.shaded.version>
<debezium.version>1.9.8.Final</debezium.version>
Expand Down
4 changes: 2 additions & 2 deletions tools/cdcup/src/app.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,8 @@
FLINK_VERSIONS = %w[
1.17.2
1.18.1
1.19.1
1.20.0
1.19.2
1.20.1
].freeze

FLINK_CDC_VERSIONS = %w[
Expand Down
2 changes: 1 addition & 1 deletion tools/mig-test/datastream/datastream-3.2.1/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ limitations under the License.

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.19.1</flink.version>
<flink.version>1.19.2</flink.version>
<flink.cdc.version>3.2.1</flink.cdc.version>
<debezium.version>1.9.8.Final</debezium.version>
<scala.binary.version>2.12</scala.binary.version>
Expand Down
2 changes: 1 addition & 1 deletion tools/mig-test/datastream/datastream-3.3.0/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ limitations under the License.

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.19.1</flink.version>
<flink.version>1.19.2</flink.version>
<flink.cdc.version>3.3.0</flink.cdc.version>
<debezium.version>1.9.8.Final</debezium.version>
<scala.binary.version>2.12</scala.binary.version>
Expand Down
2 changes: 1 addition & 1 deletion tools/mig-test/datastream/datastream-3.4-SNAPSHOT/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ limitations under the License.

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.19.1</flink.version>
<flink.version>1.19.2</flink.version>
<flink.cdc.version>3.4-SNAPSHOT</flink.cdc.version>
<debezium.version>1.9.8.Final</debezium.version>
<scala.binary.version>2.12</scala.binary.version>
Expand Down
4 changes: 2 additions & 2 deletions tools/mig-test/run_migration_test.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -118,8 +118,8 @@ def test_migration(from_version, to_version)
end

version_list = case ARGV[0]
when '1.19.1' then %w[3.2.0 3.2.1 3.3.0 3.4-SNAPSHOT]
when '1.20.0' then %w[3.2.1 3.3.0 3.4-SNAPSHOT]
when '1.19.2' then %w[3.2.0 3.2.1 3.3.0 3.4-SNAPSHOT]
when '1.20.1' then %w[3.2.1 3.3.0 3.4-SNAPSHOT]
else throw "Unknown Flink target version: #{ARGV[0]}."
end

Expand Down
Loading