Merge branch 'apache:master' into master

Author: tejanshrana

.github/workflows/flink_cdc_ci.yml

@@ -84,13 +84,13 @@ jobs:
     uses: ./.github/workflows/flink_cdc_base.yml
     with:
       java-versions: "[8]"
-      flink-versions: "['1.19.2', '1.20.1']"
+      flink-versions: "['1.19.3', '1.20.3']"
       modules: "['pipeline_e2e']"
       parallelism: ${{ matrix.parallelism }}
   source_e2e:
     name: Source E2E Tests
     uses: ./.github/workflows/flink_cdc_base.yml
     with:
       java-versions: "[8]"
-      flink-versions: "['1.19.2', '1.20.1']"
+      flink-versions: "['1.19.3', '1.20.3']"
       modules: "['source_e2e']"

.github/workflows/flink_cdc_ci_nightly.yml

@@ -78,7 +78,7 @@ jobs:
     uses: ./.github/workflows/flink_cdc_base.yml
     with:
       java-versions: "[11]"
-      flink-versions: "['1.19.2', '1.20.1']"
+      flink-versions: "['1.19.3', '1.20.3']"
       modules: "['pipeline_e2e']"
       parallelism: ${{ matrix.parallelism }}
   source_e2e:
@@ -87,5 +87,5 @@ jobs:
     uses: ./.github/workflows/flink_cdc_base.yml
     with:
       java-versions: "[11]"
-      flink-versions: "['1.19.2', '1.20.1']"
+      flink-versions: "['1.19.3', '1.20.3']"
       modules: "['source_e2e']"

docs/content.zh/docs/get-started/quickstart/cdc-up-quickstart-guide.md

@@ -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.2
-‣ 1.20.1
+  1.19.3
+‣ 1.20.3
 ```
 
 Use the arrow keys to navigate and press Enter to select specified Flink and CDC version, source, and sink connectors.

docs/content.zh/docs/get-started/quickstart/mysql-to-doris.md

@@ -33,11 +33,11 @@ under the License.
 准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。
 
 ### 准备 Flink Standalone 集群
-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 所在目录。
+1. 下载 [Flink 1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)，解压后得到 flink-1.20.3 目录。
+   使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.20.3 所在目录。
 
    ```shell
-   cd flink-1.20.1
+   cd flink-1.20.3
    ```
 
 2. 通过在 conf/config.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
@@ -340,7 +340,7 @@ Flink CDC 提供了将源表的表结构/数据路由到其他表名的配置，
    ```shell
    docker-compose down
    ```
-在 Flink 所在目录 `flink-1.20.1` 下执行如下命令停止 Flink 集群：
+在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
 
    ```shell
    ./bin/stop-cluster.sh

docs/content.zh/docs/get-started/quickstart/mysql-to-kafka.md

@@ -34,13 +34,13 @@ under the License.
 准备一台已经安装了 Docker 的 Linux 或者 macOS 电脑。
 
 ### 准备 Flink Standalone 集群
-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 所在目录。
+1. 下载 [Flink 1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz)，解压后得到 flink-1.20.3 目录。
+   使用下面的命令跳转至 Flink 目录下，并且设置 `FLINK_HOME` 为 flink-1.20.3 所在目录。
 
     ```shell
-    tar -zxvf flink-1.20.1-bin-scala_2.12.tgz
-    exprot FLINK_HOME=$(pwd)/flink-1.20.1
-    cd flink-1.20.1
+    tar -zxvf flink-1.20.3-bin-scala_2.12.tgz
+    exprot FLINK_HOME=$(pwd)/flink-1.20.3
+    cd flink-1.20.3
     ```
 
 2. 在 `conf/config.yaml` 配置文件追加下列参数开启检查点，每隔 3 秒进行一次 checkpoint。
@@ -623,7 +623,7 @@ pipeline:
 docker compose down
 ```
 
-在 Flink 所在目录 `flink-1.20.1` 下执行如下命令停止 Flink 集群：
+在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
 
 ```shell
 ./bin/stop-cluster.sh

docs/content.zh/docs/get-started/quickstart/mysql-to-starrocks.md

@@ -33,11 +33,11 @@ under the License.
 准备一台已经安装了 Docker 的 Linux 或者 MacOS 电脑。
 
 ### 准备 Flink Standalone 集群
-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 所在目录。
+1. 下载 [Flink 1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz) ，解压后得到 flink-1.20.3 目录。
+   使用下面的命令跳转至 Flink 目录下，并且设置 FLINK_HOME 为 flink-1.20.3 所在目录。
 
    ```shell
-   cd flink-1.20.1
+   cd flink-1.20.3
    ```
 
 2. 通过在 conf/config.yaml 配置文件追加下列参数开启 checkpoint，每隔 3 秒做一次 checkpoint。
@@ -308,7 +308,7 @@ Flink CDC 提供了将源表的表结构/数据路由到其他表名的配置，
    docker-compose down
    ```
 
-在 Flink 所在目录 `flink-1.20.1` 下执行如下命令停止 Flink 集群：
+在 Flink 所在目录 `flink-1.20.3` 下执行如下命令停止 Flink 集群：
 
    ```shell
    ./bin/stop-cluster.sh

docs/content/docs/get-started/quickstart/cdc-up-quickstart-guide.md

@@ -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.2
-‣ 1.20.1
+  1.19.3
+‣ 1.20.3
 ```
 
 Use the arrow keys to navigate and press Enter to select specified Flink and CDC version, source, and sink connectors.

docs/content/docs/get-started/quickstart/mysql-to-doris.md

@@ -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.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.
+1. Download [Flink 1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz) ，unzip and get flink-1.20.3 directory.
+   Use the following command to navigate to the Flink directory and set FLINK_HOME to the directory where flink-1.20.3 is located.
 
    ```shell
-   cd flink-1.20.1
+   cd flink-1.20.3
    ```
 
 2. Enable checkpointing by appending the following parameters to the conf/config.yaml configuration file to perform a checkpoint every 3 seconds.
@@ -345,7 +345,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.20.1`:
+Run the following command to stop the Flink cluster in the directory of Flink `flink-1.20.3`:
 
    ```shell
    ./bin/stop-cluster.sh

docs/content/docs/get-started/quickstart/mysql-to-kafka.md

@@ -36,13 +36,13 @@ without a single line of Java/Scala code or IDE installation.
 You need a Linux or macOS computer with Docker installed before starting.
 
 ### Prepare Flink Standalone cluster
-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 it and enter `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.
+1. Download [Flink 1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz), unzip it and enter `flink-1.20.3` directory.
+   Use the following command to navigate to the Flink directory and set `FLINK_HOME` to the directory where flink-1.20.3 is located.
 
    ```shell
-   tar -zxvf flink-1.20.1-bin-scala_2.12.tgz
-   exprot FLINK_HOME=$(pwd)/flink-1.20.1
-   cd flink-1.20.1
+   tar -zxvf flink-1.20.3-bin-scala_2.12.tgz
+   exprot FLINK_HOME=$(pwd)/flink-1.20.3
+   cd flink-1.20.3
    ```
 
 2. Enable checkpointing by appending the following parameters to the `conf/config.yaml` configuration file to perform a checkpoint every 3 seconds.

docs/content/docs/get-started/quickstart/mysql-to-starrocks.md

@@ -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.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.
+1. Download [Flink 1.20.3](https://archive.apache.org/dist/flink/flink-1.20.3/flink-1.20.3-bin-scala_2.12.tgz) ，unzip and get flink-1.20.3 directory.
+   Use the following command to navigate to the Flink directory and set FLINK_HOME to the directory where flink-1.20.3 is located.
 
    ```shell
-   cd flink-1.20.1
+   cd flink-1.20.3
    ```
 
 2. Enable checkpointing by appending the following parameters to the conf/config.yaml configuration file to perform a checkpoint every 3 seconds.