[jira] [Assigned] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35386: - Assignee: Zhongqiang Gong (was: Qingsheng Ren) > Build Flink CDC 3.1 Documentation

[jira] [Resolved] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35386. --- Resolution: Fixed > Build Flink CDC 3.1 Documentation and mark it as stable >

[jira] [Commented] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

[ https://issues.apache.org/jira/browse/FLINK-35386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847155#comment-17847155 ] Qingsheng Ren commented on FLINK-35386: --- flink-cdc master:

[jira] [Created] (FLINK-35386) Build Flink CDC 3.1 Documentation and mark it as stable

Qingsheng Ren created FLINK-35386: - Summary: Build Flink CDC 3.1 Documentation and mark it as stable Key: FLINK-35386 URL: https://issues.apache.org/jira/browse/FLINK-35386 Project: Flink

[jira] [Resolved] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35309. --- Resolution: Fixed > Enable Notice file ci check and fix Notice >

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34990: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) >

[jira] [Closed] (FLINK-34912) Replace all occurrences of com.ververica in the project with org.apache.flink

[ https://issues.apache.org/jira/browse/FLINK-34912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-34912. - Resolution: Duplicate > Replace all occurrences of com.ververica in the project with

[jira] [Updated] (FLINK-34908) [Feature][Pipeline] Mysql pipeline to doris and starrocks will lost precision for timestamp

[ https://issues.apache.org/jira/browse/FLINK-34908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34908: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature][Pipeline] Mysql

[jira] [Updated] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

[ https://issues.apache.org/jira/browse/FLINK-34904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34904: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature] submit Flink CDC

[jira] [Assigned] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34752: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese

[jira] [Updated] (FLINK-34752) "legacy-flink-cdc-sources" Page of TIDB for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34752: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34750: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34750) "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34750: - Assignee: Hongshun Wang > "legacy-flink-cdc-sources" Page of Postgresql for Flink CDC

[jira] [Updated] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34748: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Updated] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34749: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34748) "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34748: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of Oracle for Flink CDC Chinese

[jira] [Updated] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34747: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "legacy-flink-cdc-sources"

[jira] [Assigned] (FLINK-34749) "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34749: - Assignee: 牛一凡 > "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese >

[jira] [Assigned] (FLINK-34747) "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.

[ https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34747: - Assignee: Xiao Huang > "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese

[jira] [Updated] (FLINK-34735) "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34735: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Developer Guide -

[jira] [Assigned] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34736: - Assignee: Vincent Woo > "Deployment - Standalone" Page for Flink CDC Chinese

[jira] [Updated] (FLINK-34736) "Deployment - Standalone" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34736: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - Standalone"

[jira] [Updated] (FLINK-34730) Translate pages of Flink CDC docs to Chinese

[ https://issues.apache.org/jira/browse/FLINK-34730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34730: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Translate pages of Flink

[jira] [Updated] (FLINK-35354) Support host mapping in Flink tikv cdc

[ https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35354: -- Fix Version/s: (was: cdc-3.1.0) > Support host mapping in Flink tikv cdc >

[jira] [Resolved] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35259. --- Resolution: Fixed > FlinkCDC Pipeline transform can't deal timestamp field >

[jira] [Comment Edited] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841824#comment-17841824 ] Qingsheng Ren edited comment on FLINK-35259 at 5/17/24 3:24 AM:

[jira] [Updated] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

[ https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34944: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Use Incremental Source

[jira] [Assigned] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

[ https://issues.apache.org/jira/browse/FLINK-34944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34944: - Assignee: He Wang > Use Incremental Source Framework in Flink CDC OceanBase Source

[jira] [Updated] (FLINK-34853) [Feature] submit Flink CDC pipeline job to k8s cluster.

[ https://issues.apache.org/jira/browse/FLINK-34853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34853: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > [Feature] submit Flink CDC

[jira] [Updated] (FLINK-34737) "Deployment - Kubernetes" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34737: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - Kubernetes"

[jira] [Updated] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34738: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > "Deployment - YARN" Page

[jira] [Updated] (FLINK-34638) Support default value of table column.

[ https://issues.apache.org/jira/browse/FLINK-34638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34638: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Support default value of

[jira] [Resolved] (FLINK-34614) Add e2e test for Flink CDC pipeline job.

[ https://issues.apache.org/jira/browse/FLINK-34614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34614. --- Assignee: LvYanquan Resolution: Fixed > Add e2e test for Flink CDC pipeline job. >

[jira] [Updated] (FLINK-34595) Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils

[ https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34595: -- Fix Version/s: cdc-3.2.0 (was: cdc-3.1.0) > Fix

[jira] [Commented] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845257#comment-17845257 ] Qingsheng Ren commented on FLINK-35309: --- CDC release-3.1:

[jira] [Assigned] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35309: - Assignee: Zhongqiang Gong > Enable Notice file ci check and fix Notice >

[jira] [Updated] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35309: -- Fix Version/s: cdc-3.1.0 > Enable Notice file ci check and fix Notice >

[jira] [Updated] (FLINK-35309) Enable Notice file ci check and fix Notice

[ https://issues.apache.org/jira/browse/FLINK-35309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35309: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > Enable Notice file ci

[jira] [Assigned] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35067: - Assignee: Vallari Rastogi > Support metadata 'op_type' virtual column for Postgres

[jira] [Closed] (FLINK-34666) Keep assigned splits in order to fix wrong meta group calculation

[ https://issues.apache.org/jira/browse/FLINK-34666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-34666. - Resolution: Fixed > Keep assigned splits in order to fix wrong meta group calculation >

[jira] [Commented] (FLINK-35264) Flink CDC Pipeline transform rules do not take effect

[ https://issues.apache.org/jira/browse/FLINK-35264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841969#comment-17841969 ] Qingsheng Ren commented on FLINK-35264: --- flink-cdc master:

[jira] [Resolved] (FLINK-35264) Flink CDC Pipeline transform rules do not take effect

[ https://issues.apache.org/jira/browse/FLINK-35264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35264. --- Fix Version/s: cdc-3.1.0 Resolution: Fixed > Flink CDC Pipeline transform rules do

[jira] [Assigned] (FLINK-35264) Flink CDC Pipeline transform rules do not take effect

[ https://issues.apache.org/jira/browse/FLINK-35264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35264: - Assignee: yux > Flink CDC Pipeline transform rules do not take effect >

[jira] [Resolved] (FLINK-34180) Accept Flink CDC project as part of Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-34180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34180. --- Resolution: Fixed > Accept Flink CDC project as part of Apache Flink >

[jira] [Closed] (FLINK-34185) Remove unwanted bundle dependencies

[ https://issues.apache.org/jira/browse/FLINK-34185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-34185. - Fix Version/s: cdc-3.1.0 Resolution: Fixed > Remove unwanted bundle dependencies >

[jira] [Resolved] (FLINK-34317) Cleanup pending Flink CDC issues on GitHub

[ https://issues.apache.org/jira/browse/FLINK-34317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34317. --- Resolution: Done > Cleanup pending Flink CDC issues on GitHub >

[jira] [Commented] (FLINK-34317) Cleanup pending Flink CDC issues on GitHub

[ https://issues.apache.org/jira/browse/FLINK-34317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841898#comment-17841898 ] Qingsheng Ren commented on FLINK-34317: --- All issues have been imported to Jira:

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

[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34903. --- Assignee: Thorne Resolution: Fixed > Add mysql-pipeline-connector with tables.exclude

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

[ https://issues.apache.org/jira/browse/FLINK-34903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841895#comment-17841895 ] Qingsheng Ren commented on FLINK-34903: --- flink-cdc master:

[jira] [Commented] (FLINK-35127) CDC ValuesDataSourceITCase crashed due to OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841894#comment-17841894 ] Qingsheng Ren commented on FLINK-35127: --- flink-cdc master:

[jira] [Resolved] (FLINK-35127) CDC ValuesDataSourceITCase crashed due to OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35127. --- Resolution: Fixed > CDC ValuesDataSourceITCase crashed due to OutOfMemoryError >

[jira] [Comment Edited] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841825#comment-17841825 ] Qingsheng Ren edited comment on FLINK-34878 at 4/29/24 8:22 AM:

[jira] [Resolved] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34878. --- Resolution: Fixed > [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN >

[jira] [Comment Edited] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841827#comment-17841827 ] Qingsheng Ren edited comment on FLINK-35255 at 4/29/24 7:24 AM:

[jira] [Resolved] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35255. --- Resolution: Fixed > DataSinkWriterOperator should override snapshotState and

[jira] [Commented] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841827#comment-17841827 ] Qingsheng Ren commented on FLINK-35255: --- flink-cdc master:

[jira] [Assigned] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35255: - Assignee: yanghuai > DataSinkWriterOperator should override snapshotState and

[jira] [Updated] (FLINK-35255) DataSinkWriterOperator should override snapshotState and processWatermark method

[ https://issues.apache.org/jira/browse/FLINK-35255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35255: -- Fix Version/s: cdc-3.1.0 > DataSinkWriterOperator should override snapshotState and

[jira] [Commented] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841825#comment-17841825 ] Qingsheng Ren commented on FLINK-34878: --- flink-cdc master:

[jira] [Assigned] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34878: - Assignee: Wenkai Qi > [Feature][Pipeline] Flink CDC pipeline transform supports CASE

[jira] [Updated] (FLINK-34878) [Feature][Pipeline] Flink CDC pipeline transform supports CASE WHEN

[ https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34878: -- Fix Version/s: cdc-3.1.0 > [Feature][Pipeline] Flink CDC pipeline transform supports CASE

[jira] [Assigned] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35259: - Assignee: Wenkai Qi > FlinkCDC Pipeline transform can't deal timestamp field >

[jira] [Commented] (FLINK-35259) FlinkCDC Pipeline transform can't deal timestamp field

[ https://issues.apache.org/jira/browse/FLINK-35259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841824#comment-17841824 ] Qingsheng Ren commented on FLINK-35259: --- flink-cdc master:

[jira] [Resolved] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35258. --- Resolution: Fixed > Broken links to Doris in Flink CDC Documentation >

[jira] [Assigned] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35258: - Assignee: yux (was: Qingsheng Ren) > Broken links to Doris in Flink CDC

[jira] [Commented] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

[ https://issues.apache.org/jira/browse/FLINK-35258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841813#comment-17841813 ] Qingsheng Ren commented on FLINK-35258: --- flink-cdc master:

[jira] [Resolved] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35251. --- Resolution: Fixed > SchemaDerivation serializes mapping incorrectly on checkpoint >

[jira] [Comment Edited] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841551#comment-17841551 ] Qingsheng Ren edited comment on FLINK-35251 at 4/29/24 2:25 AM: fixed in

[jira] [Resolved] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35256. --- Resolution: Fixed > Pipeline transform ignores column type nullability >

[jira] [Comment Edited] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841641#comment-17841641 ] Qingsheng Ren edited comment on FLINK-35256 at 4/29/24 2:23 AM:

[jira] [Updated] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35256: -- Fix Version/s: cdc-3.1.0 > Pipeline transform ignores column type nullability >

[jira] [Assigned] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35256: - Assignee: yux > Pipeline transform ignores column type nullability >

[jira] [Commented] (FLINK-35256) Pipeline transform ignores column type nullability

[ https://issues.apache.org/jira/browse/FLINK-35256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841641#comment-17841641 ] Qingsheng Ren commented on FLINK-35256: --- flink-cdc master:

[jira] [Created] (FLINK-35258) Broken links to Doris in Flink CDC Documentation

Qingsheng Ren created FLINK-35258: - Summary: Broken links to Doris in Flink CDC Documentation Key: FLINK-35258 URL: https://issues.apache.org/jira/browse/FLINK-35258 Project: Flink Issue

[jira] [Created] (FLINK-35251) SchemaDerivation serializes mapping incorrectly on checkpoint

Qingsheng Ren created FLINK-35251: - Summary: SchemaDerivation serializes mapping incorrectly on checkpoint Key: FLINK-35251 URL: https://issues.apache.org/jira/browse/FLINK-35251 Project: Flink

[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35173: -- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > Debezium for Mysql

[jira] [Updated] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35173: -- Fix Version/s: cdc-3.1.0 (was: 3.1.0) > Debezium for Mysql connector

[jira] [Resolved] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35173. --- Resolution: Fixed > Debezium for Mysql connector Custom Time Serializer >

[jira] [Assigned] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35173: - Assignee: ZhengYu Chen > Debezium for Mysql connector Custom Time Serializer >

[jira] [Commented] (FLINK-35173) Debezium for Mysql connector Custom Time Serializer

[ https://issues.apache.org/jira/browse/FLINK-35173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841109#comment-17841109 ] Qingsheng Ren commented on FLINK-35173: --- flink-cdc release-3.1:

[jira] [Resolved] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34639. --- Resolution: Fixed > Flink CDC: Support DebeziumDeserializationSchema in OceanBase source

[jira] [Comment Edited] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840683#comment-17840683 ] Qingsheng Ren edited comment on FLINK-34639 at 4/26/24 3:32 AM:

[jira] [Comment Edited] (FLINK-35128) Re-calculate the starting change log offset after the new table added

[ https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840657#comment-17840657 ] Qingsheng Ren edited comment on FLINK-35128 at 4/26/24 3:30 AM:

[jira] [Resolved] (FLINK-35128) Re-calculate the starting change log offset after the new table added

[ https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35128. --- Fix Version/s: cdc-3.1.0 (was: 3.1.0) Resolution: Fixed >

[jira] [Assigned] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34639: - Assignee: He Wang > Flink CDC: Support DebeziumDeserializationSchema in OceanBase

[jira] [Commented] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840683#comment-17840683 ] Qingsheng Ren commented on FLINK-34639: --- flink-cdc master:

[jira] [Commented] (FLINK-35128) Re-calculate the starting change log offset after the new table added

[ https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840657#comment-17840657 ] Qingsheng Ren commented on FLINK-35128: --- flink-cdc master:

[jira] [Resolved] (FLINK-34188) Setup release infrastructure for Flink CDC project

[ https://issues.apache.org/jira/browse/FLINK-34188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34188. --- Resolution: Fixed > Setup release infrastructure for Flink CDC project >

[jira] [Commented] (FLINK-34188) Setup release infrastructure for Flink CDC project

[ https://issues.apache.org/jira/browse/FLINK-34188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840326#comment-17840326 ] Qingsheng Ren commented on FLINK-34188: --- flink-cdc master:

[jira] [Assigned] (FLINK-34869) [Bug][mysql] Remove all previous table and add new added table will throw Exception.

[ https://issues.apache.org/jira/browse/FLINK-34869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34869: - Assignee: Josh Mahonin > [Bug][mysql] Remove all previous table and add new added

[jira] [Resolved] (FLINK-35055) Flink CDC connector release contains dependency with incompatible licenses

[ https://issues.apache.org/jira/browse/FLINK-35055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35055. --- Fix Version/s: cdc-3.1.0 Resolution: Fixed > Flink CDC connector release contains

[jira] [Commented] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19

[ https://issues.apache.org/jira/browse/FLINK-34969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840047#comment-17840047 ] Qingsheng Ren commented on FLINK-34969: --- flink-cdc master:

[jira] [Resolved] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19

[ https://issues.apache.org/jira/browse/FLINK-34969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34969. --- Resolution: Fixed > Error due to Flink CDC using deprecated flink-conf.yaml in light of

[jira] [Updated] (FLINK-35167) Introduce MaxCompute pipeline DataSink

[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-35167: -- Fix Version/s: cdc-3.2.0 > Introduce MaxCompute pipeline DataSink >

[jira] [Assigned] (FLINK-35167) Introduce MaxCompute pipeline DataSink

[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35167: - Assignee: zhangdingxin > Introduce MaxCompute pipeline DataSink >

[jira] [Assigned] (FLINK-35092) Add integrated test for Doris / Starrocks sink pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35092: - Assignee: Xiqian YU > Add integrated test for Doris / Starrocks sink pipeline

[jira] [Assigned] (FLINK-35072) Doris pipeline sink does not support applying AlterColumnTypeEvent

[ https://issues.apache.org/jira/browse/FLINK-35072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35072: - Assignee: Xiqian YU > Doris pipeline sink does not support applying

[jira] [Closed] (FLINK-35144) Support various sources sync for FlinkCDC in one pipeline

[ https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-35144. - Resolution: Duplicate > Support various sources sync for FlinkCDC in one pipeline >

[jira] [Assigned] (FLINK-35077) Add package license check for Flink CDC modules.

[ https://issues.apache.org/jira/browse/FLINK-35077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35077: - Assignee: Xiqian YU > Add package license check for Flink CDC modules. >

[jira] [Assigned] (FLINK-35102) Incorret Type mapping for Flink CDC Doris connector

[ https://issues.apache.org/jira/browse/FLINK-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-35102: - Assignee: Xiqian YU > Incorret Type mapping for Flink CDC Doris connector >

  1   2   3   4   5   6   7   8   9   10   >