[jira] [Created] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

2024-06-13 Thread Di Wu (Jira)
Di Wu created FLINK-35600: - Summary: Data read duplication during the full-to-incremental conversion phase Key: FLINK-35600 URL: https://issues.apache.org/jira/browse/FLINK-35600 Project: Flink Issu

[jira] [Updated] (FLINK-35600) Data read duplication during the full-to-incremental conversion phase

2024-06-13 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-35600: -- Description: Assume that the table has been split into 3 Chunks Timeline t1: chunk1 is read t2: a piece of da

[jira] [Created] (FLINK-35838) FLIP-399: Flink Connector Doris

2024-07-15 Thread Di Wu (Jira)
Di Wu created FLINK-35838: - Summary: FLIP-399: Flink Connector Doris Key: FLINK-35838 URL: https://issues.apache.org/jira/browse/FLINK-35838 Project: Flink Issue Type: New Feature Reporte

[jira] [Created] (FLINK-35839) Migrate repo from apache/doris to apache/flink

2024-07-15 Thread Di Wu (Jira)
Di Wu created FLINK-35839: - Summary: Migrate repo from apache/doris to apache/flink Key: FLINK-35839 URL: https://issues.apache.org/jira/browse/FLINK-35839 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35840) Add documentation for Doris

2024-07-15 Thread Di Wu (Jira)
Di Wu created FLINK-35840: - Summary: Add documentation for Doris Key: FLINK-35840 URL: https://issues.apache.org/jira/browse/FLINK-35840 Project: Flink Issue Type: Sub-task Reporter: Di W

[jira] [Created] (FLINK-35841) Change package name to org.apache.flink

2024-07-15 Thread Di Wu (Jira)
Di Wu created FLINK-35841: - Summary: Change package name to org.apache.flink Key: FLINK-35841 URL: https://issues.apache.org/jira/browse/FLINK-35841 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-35842) Change the FlinkCDC dependency to 3.1.x

2024-07-15 Thread Di Wu (Jira)
Di Wu created FLINK-35842: - Summary: Change the FlinkCDC dependency to 3.1.x Key: FLINK-35842 URL: https://issues.apache.org/jira/browse/FLINK-35842 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

2024-10-30 Thread Di Wu (Jira)
Di Wu created FLINK-36631: - Summary: Supports reading incremental data from Oracle from a specified SCN Key: FLINK-36631 URL: https://issues.apache.org/jira/browse/FLINK-36631 Project: Flink Issue T

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-03 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Description: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed.   {code

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Fix Version/s: 3.0.0 > Oracle When reading via OracleIncrementalSource, the connection is > occasionally clos

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Description: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed.     >

[jira] [Updated] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-10 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36687: -- Description: Update Doris Pipeline Connector Version to 24.0.1 Improve Doris Pipeline Connector Version to 24

[jira] [Updated] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-10 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36687: -- Description: Improve Doris Pipeline Connector Version to 24.0.1, Related release note  [apache/doris-flink-con

[jira] [Closed] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-11 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu closed FLINK-36687. - Resolution: Resolved > Improve Doris Pipeline Connector Version to 24.0.1 >

[jira] [Commented] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-11 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897140#comment-17897140 ] Di Wu commented on FLINK-36687: --- This has been resolved here https://github.com/apache/fli

[jira] [Created] (FLINK-36687) Improve Doris Pipeline Connector Version to 24.0.1

2024-11-10 Thread Di Wu (Jira)
Di Wu created FLINK-36687: - Summary: Improve Doris Pipeline Connector Version to 24.0.1 Key: FLINK-36687 URL: https://issues.apache.org/jira/browse/FLINK-36687 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-36397) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

2024-11-11 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17897115#comment-17897115 ] Di Wu commented on FLINK-36397: --- In snapshotreader, the data from lw to hw will be replaye

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Fix Version/s: cdc-3.3.0 (was: 3.0.0) > Oracle When reading via OracleIncrementalSource

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Labels: CDC (was: ) > Oracle When reading via OracleIncrementalSource, the connection is > occasionally clos

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Affects Version/s: cdc-3.1.1 cdc-3.2.0 cdc-3.3.0 > Oracle When r

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Description: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed.   {code

[jira] [Updated] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36649: -- Fix Version/s: (was: cdc-3.3.0) > Oracle When reading via OracleIncrementalSource, the connection is > oc

[jira] [Created] (FLINK-36649) Oracle When reading via OracleIncrementalSource, the connection is occasionally closed

2024-11-01 Thread Di Wu (Jira)
Di Wu created FLINK-36649: - Summary: Oracle When reading via OracleIncrementalSource, the connection is occasionally closed Key: FLINK-36649 URL: https://issues.apache.org/jira/browse/FLINK-36649 Project: Fli

[jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

2024-11-01 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36631: -- Affects Version/s: cdc-3.1.1 cdc-3.2.0 cdc-3.1.0

[jira] [Updated] (FLINK-36813) MySQLCDC supports synchronization of specified fields

2024-11-27 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36813: -- Description: *Background* In some scenarios, MySQL synchronization only expects to synchronize specified fiel

[jira] [Created] (FLINK-36813) MySQLCDC supports synchronization of specified fields

2024-11-27 Thread Di Wu (Jira)
Di Wu created FLINK-36813: - Summary: MySQLCDC supports synchronization of specified fields Key: FLINK-36813 URL: https://issues.apache.org/jira/browse/FLINK-36813 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-36631) Supports reading incremental data from Oracle from a specified SCN

2025-01-22 Thread Di Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Di Wu updated FLINK-36631: -- Fix Version/s: cdc-3.4.0 > Supports reading incremental data from Oracle from a specified SCN > --