[jira] [Commented] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed

2025-01-02 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909333#comment-17909333 ] Thorne commented on FLINK-36996: I will fix it  > The schema and namespace of MySQL pip

[jira] [Updated] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed

2025-01-02 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36996: --- Description: As show that : 1、mysql2doris yaml with metadata config {code:java} //代码占位符 #

[jira] [Created] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed

2025-01-02 Thread Thorne (Jira)
Thorne created FLINK-36996: -- Summary: The schema and namespace of MySQL pipeline connector metadata are reversed Key: FLINK-36996 URL: https://issues.apache.org/jira/browse/FLINK-36996 Project: Flink

[jira] [Updated] (FLINK-36952) Fix MongoDB connector Chinese documentation

2024-12-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36952: --- Summary: Fix MongoDB connector Chinese documentation (was: Fix mongodb connector chinese doc) > Fix MongoD

[jira] [Updated] (FLINK-36952) Fix mongodb connector chinese doc

2024-12-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36952: --- Summary: Fix mongodb connector chinese doc (was: Fix mongodb chinese doc) > Fix mongodb connector chinese d

[jira] [Updated] (FLINK-36952) Fix mongodb chinese doc

2024-12-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36952: --- Summary: Fix mongodb chinese doc (was: fix mongodb chinese doc) > Fix mongodb chinese doc > ---

[jira] [Commented] (FLINK-36952) fix mongodb chinese doc

2024-12-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907808#comment-17907808 ] Thorne commented on FLINK-36952: I will fix it > fix mongodb chinese doc >

[jira] [Created] (FLINK-36952) fix mongodb chinese doc

2024-12-23 Thread Thorne (Jira)
Thorne created FLINK-36952: -- Summary: fix mongodb chinese doc Key: FLINK-36952 URL: https://issues.apache.org/jira/browse/FLINK-36952 Project: Flink Issue Type: Improvement Components: Fli

[jira] [Commented] (FLINK-36676) Flink CDC SQL Server Connector Missing Data

2024-12-04 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903169#comment-17903169 ] Thorne commented on FLINK-36676: I suggest  that u  can propose a work order in aliyun c

[jira] [Commented] (FLINK-36829) Add better validation of pipeline config

2024-12-03 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17902593#comment-17902593 ] Thorne commented on FLINK-36829: Hi ,thanks u for your issues and can u give me the yaml

[jira] [Created] (FLINK-36224) Add the version mapping between pipeline connectors and flink

2024-09-04 Thread Thorne (Jira)
Thorne created FLINK-36224: -- Summary: Add the version mapping between pipeline connectors and flink Key: FLINK-36224 URL: https://issues.apache.org/jira/browse/FLINK-36224 Project: Flink Issue Typ

[jira] [Updated] (FLINK-36165) Support capturing snapshot data with where conditions

2024-09-03 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Summary: Support capturing snapshot data with where conditions (was: Support capturing snapshot data of the

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-09-01 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: 1. When I want to supplement some data (business consumption data failed) 2. Unable to start fr

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-09-01 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: 1. When I want to supplement some data (business consumption data failed) 2. Unable to start fr

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-09-01 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: 1. When I want to supplement some data (business consumption data failed) 2. Unable to start fr

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-09-01 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: 1. When I want to supplement some data (business consumption data failed) 2. Unable to start fr

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-09-01 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: 1. When I want to supplement some data (business consumption data failed) 2. Unable to start fr

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-08-27 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: Just like Datax,user just obtain data from database without all snapshot data. {code:java} sele

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-08-27 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Attachment: image-2024-08-28-14-06-40-501.png > Support obtaining snapshot data of the scope > -

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-08-27 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: just like datax,user just obtain data from database without all sna {code:java} select * from w

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-08-27 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: Just like datax,user just obtain data from database without all snapshot data. {code:java} sele

[jira] [Updated] (FLINK-36165) Support obtaining snapshot data of the scope

2024-08-27 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-36165: --- Description: just like datax,user can  {code:java} select * from where col >x1 and col x1 and col Support o

[jira] [Created] (FLINK-36165) Support obtaining snapshot data of the scope

2024-08-27 Thread Thorne (Jira)
Thorne created FLINK-36165: -- Summary: Support obtaining snapshot data of the scope Key: FLINK-36165 URL: https://issues.apache.org/jira/browse/FLINK-36165 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-35056) when initial sqlserver table that's primary key is datetime type, it org.apache.flink.table.api.ValidationException: Timestamp precision must be between 0 and 9 (both

2024-08-20 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875339#comment-17875339 ] Thorne commented on FLINK-35056: The version of flink-cdc is to old, can u try the lates

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35919: --- Description: !image-2024-07-30-11-37-11-346.png!  op_type option is easier to understand  was:op_type op

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35919: --- Attachment: image-2024-07-30-11-37-11-346.png > The rowkind keyword option for MySQL connector metadata shou

[jira] [Comment Edited] (FLINK-35913) The issue of using StreamExecutioneEnvironment to execute multiple jobs in a program on Flink CDC

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869289#comment-17869289 ] Thorne edited comment on FLINK-35913 at 7/29/24 11:19 AM: -- I do

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35919: --- Description: op_type option is easier to understand  (was: The op_type option is easier to understand ) >

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35919: --- Description: The op_type option is easier to understand > The rowkind keyword option for MySQL connector met

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35919: --- Description: The op_type option is easier to understand  (was: The op_type option is easier to understand)

[jira] [Updated] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35919: --- Summary: The rowkind keyword option for MySQL connector metadata should be changed to op_type keyword (was:

[jira] [Created] (FLINK-35919) The rowkind keyword option for MySQL connector metadata should be changed to the op_type keyword

2024-07-29 Thread Thorne (Jira)
Thorne created FLINK-35919: -- Summary: The rowkind keyword option for MySQL connector metadata should be changed to the op_type keyword Key: FLINK-35919 URL: https://issues.apache.org/jira/browse/FLINK-35919

[jira] [Commented] (FLINK-35913) The issue of using StreamExecutioneEnvironment to execute multiple jobs in a program on Flink CDC

2024-07-29 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869289#comment-17869289 ] Thorne commented on FLINK-35913: I don't recommend  that starting  a flink's job with sp

[jira] [Updated] (FLINK-35674) MySQL connector cause blocking when searching for binlog file‘s timestamp

2024-06-24 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Updated] (FLINK-35674) MySQL connector cause blocking when searching for binlog file‘s timestamp

2024-06-24 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Summary: MySQL connector cause blocking when searching for binlog file‘s timestamp (was: MySQL connector ca

[jira] [Updated] (FLINK-35674) MySQL connector cause blocking when searching for binlog timestamps

2024-06-24 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Updated] (FLINK-35674) MySQL connector may cause blocking when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Summary: MySQL connector may cause blocking when searching for binlog timestamps (was: MySQL connector may

[jira] [Commented] (FLINK-35674) MySQL connector cause blocking when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859566#comment-17859566 ] Thorne commented on FLINK-35674: I wil fix it  > MySQL connector cause blocking when se

[jira] [Updated] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Updated] (FLINK-35674) MySQL connector cause blocking when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Summary: MySQL connector cause blocking when searching for binlog timestamps (was: MySQL connector may caus

[jira] [Updated] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Updated] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Updated] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Updated] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Created] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
Thorne created FLINK-35674: -- Summary: MySQL connector may cause deadlock issues when searching for binlog timestamps Key: FLINK-35674 URL: https://issues.apache.org/jira/browse/FLINK-35674 Project: Flink

[jira] [Updated] (FLINK-35674) MySQL connector may cause deadlock issues when searching for binlog timestamps

2024-06-23 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-35674: --- Description: When a task is started by multiple mysql connector timestamp start mode at the same time, when

[jira] [Comment Edited] (FLINK-35056) when initial sqlserver table that's primary key is datetime type, it org.apache.flink.table.api.ValidationException: Timestamp precision must be between 0 and 9

2024-04-15 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837232#comment-17837232 ] Thorne edited comment on FLINK-35056 at 4/15/24 12:47 PM: -- Hi,c

[jira] [Commented] (FLINK-35056) when initial sqlserver table that's primary key is datetime type, it org.apache.flink.table.api.ValidationException: Timestamp precision must be between 0 and 9 (both

2024-04-15 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837232#comment-17837232 ] Thorne commented on FLINK-35056: Hi,can u give me a example and let me to recurrent it。

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables

2024-04-14 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Summary: Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables (was: Add my

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables

2024-04-14 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Release Note: [features] Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tab

[jira] [Commented] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829718#comment-17829718 ] Thorne commented on FLINK-34903: ok,tks,i have do it > Add mysql-pipeline-connector wit

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Description:     When using the MySQL Pipeline connector for whole-database synchronization, users currentl

[jira] [Commented] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829512#comment-17829512 ] Thorne commented on FLINK-34903: i take a pr in https://github.com/apache/flink-cdc/pull

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Attachment: screenshot-3.png > Add mysql-pipeline-connector with table.exclude.list option to exclude > un

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Attachment: screenshot-2.png > Add mysql-pipeline-connector with table.exclude.list option to exclude > un

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Attachment: screenshot-1.png > Add mysql-pipeline-connector with table.exclude.list option to exclude > un

[jira] [Updated] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thorne updated FLINK-34903: --- Docs Text: (was: i will take a pr for this) > Add mysql-pipeline-connector with table.exclude.list option

[jira] [Commented] (FLINK-34903) Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables

2024-03-21 Thread Thorne (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829418#comment-17829418 ] Thorne commented on FLINK-34903: I will take a pr for this > Add mysql-pipeline-connect