[jira] [Assigned] (FLINK-38183) Data loss when cdc reading mysql that has out of order GTID

[ https://issues.apache.org/jira/browse/FLINK-38183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38183: -- Assignee: LiuZeshan > Data loss when cdc reading mysql that has out of order GTID > -

[jira] [Assigned] (FLINK-38141) Iceberg sink has an incorrect type conversion

[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38141: -- Assignee: ZhangChao > Iceberg sink has an incorrect type conversion > ---

[jira] [Commented] (FLINK-38141) Iceberg sink has an incorrect type conversion

[ https://issues.apache.org/jira/browse/FLINK-38141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18010908#comment-18010908 ] Leonard Xu commented on FLINK-38141: Assigned to you [~doovvv]  > Iceberg sink has

[jira] [Assigned] (FLINK-38152) MySQL CDC scan.snapshot.fetch.size param is invalid

[ https://issues.apache.org/jira/browse/FLINK-38152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38152: -- Assignee: Xin Gong > MySQL CDC scan.snapshot.fetch.size param is invalid > --

[jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache

[ https://issues.apache.org/jira/browse/FLINK-38045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-38045: --- Fix Version/s: cdc-3.5.0 > Refactor: Make transform operator stateless by building a > createTableE

[jira] [Assigned] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache

[ https://issues.apache.org/jira/browse/FLINK-38045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38045: -- Assignee: wuzexian > Refactor: Make transform operator stateless by building a > createTable

[jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache

[ https://issues.apache.org/jira/browse/FLINK-38045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-38045: --- Affects Version/s: cdc-3.4.0 > Refactor: Make transform operator stateless by building a > createTa

[jira] [Commented] (FLINK-38065) Mismatching bracket in PostgresOffset#toString

[ https://issues.apache.org/jira/browse/FLINK-38065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004096#comment-18004096 ] Leonard Xu commented on FLINK-38065: Fixed in master via: 8437bc922f1dc7298ae0881302

[jira] [Closed] (FLINK-38065) Mismatching bracket in PostgresOffset#toString

[ https://issues.apache.org/jira/browse/FLINK-38065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-38065. -- Resolution: Fixed > Mismatching bracket in PostgresOffset#toString > -

[jira] [Updated] (FLINK-38065) Mismatching bracket in PostgresOffset#toString

[ https://issues.apache.org/jira/browse/FLINK-38065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-38065: --- Fix Version/s: cdc-3.5.0 > Mismatching bracket in PostgresOffset#toString >

[jira] [Updated] (FLINK-38059) [docs] Add fluss pipeline connector documentation

[ https://issues.apache.org/jira/browse/FLINK-38059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-38059: --- Fix Version/s: cdc-3.5.0 > [docs] Add fluss pipeline connector documentation > -

[jira] [Commented] (FLINK-38059) [docs] Add fluss pipeline connector documentation

[ https://issues.apache.org/jira/browse/FLINK-38059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003959#comment-18003959 ] Leonard Xu commented on FLINK-38059: Assigned to you, [~beryllwang]  > [docs] Add f

[jira] [Assigned] (FLINK-38059) [docs] Add fluss pipeline connector documentation

[ https://issues.apache.org/jira/browse/FLINK-38059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38059: -- Assignee: JunboWang > [docs] Add fluss pipeline connector documentation > ---

[jira] [Assigned] (FLINK-38065) Mismatching bracket in PostgresOffset#toString

[ https://issues.apache.org/jira/browse/FLINK-38065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38065: -- Assignee: Sergei Morozov > Mismatching bracket in PostgresOffset#toString > -

[jira] [Commented] (FLINK-38058) Add e2e test for fluss pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-38058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003951#comment-18003951 ] Leonard Xu commented on FLINK-38058: [~maheshsambaram] assigned to you, you can refe

[jira] [Assigned] (FLINK-38058) Add e2e test for fluss pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-38058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-38058: -- Assignee: Mahesh Sambaram > Add e2e test for fluss pipeline connector > -

[jira] [Created] (FLINK-38059) [docs] Add fluss pipeline connector documentation

Leonard Xu created FLINK-38059: -- Summary: [docs] Add fluss pipeline connector documentation Key: FLINK-38059 URL: https://issues.apache.org/jira/browse/FLINK-38059 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38058) Add e2e test for fluss pipeline connector

Leonard Xu created FLINK-38058: -- Summary: Add e2e test for fluss pipeline connector Key: FLINK-38058 URL: https://issues.apache.org/jira/browse/FLINK-38058 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37958: --- Priority: Major (was: Minor) > Flink CDC Sink connector support fluss > ---

[jira] [Updated] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37958: --- Affects Version/s: cdc-3.4.0 > Flink CDC Sink connector support fluss >

[jira] [Commented] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003496#comment-18003496 ] Leonard Xu commented on FLINK-37958: [~loserwang1024] [~beryllwang] I just merged yo

[jira] [Comment Edited] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003495#comment-18003495 ] Leonard Xu edited comment on FLINK-37958 at 7/7/25 11:58 AM: -

[jira] [Updated] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37958: --- Fix Version/s: cdc-3.5.0 > Flink CDC Sink connector support fluss >

[jira] [Commented] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003495#comment-18003495 ] Leonard Xu commented on FLINK-37958: merged code change via 2139824f6d554f083f760879

[jira] [Assigned] (FLINK-37958) Flink CDC Sink connector support fluss

[ https://issues.apache.org/jira/browse/FLINK-37958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37958: -- Assignee: Hongshun Wang > Flink CDC Sink connector support fluss > --

[jira] [Assigned] (FLINK-37987) Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2

[ https://issues.apache.org/jira/browse/FLINK-37987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37987: -- Assignee: Poorvank Bhatia > Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API

[jira] [Assigned] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported

[ https://issues.apache.org/jira/browse/FLINK-37891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37891: -- Assignee: Sergei Morozov > SQL Server CDC mistakenly document scan.startup.mode=initial-only

[jira] [Assigned] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE

[ https://issues.apache.org/jira/browse/FLINK-37835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37835: -- Assignee: yux > MySQL CDC BinlogOffset compareTo method throws NPE >

[jira] [Updated] (FLINK-37587) Fail to add a new column that has the same column name with source table using transform

[ https://issues.apache.org/jira/browse/FLINK-37587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37587: --- Fix Version/s: cdc-3.5.0 (was: cdc-3.4.0) > Fail to add a new column that has

[jira] [Updated] (FLINK-37641) Fix: SchemaEvolveE2eITCase.testLenientSchemaEvolution timeout

[ https://issues.apache.org/jira/browse/FLINK-37641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37641: --- Fix Version/s: cdc-3.5.0 (was: cdc-3.4.0) > Fix: SchemaEvolveE2eITCase.testLe

[jira] [Updated] (FLINK-37762) No Infomation in Overview at Flink CDC 3.4

[ https://issues.apache.org/jira/browse/FLINK-37762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37762: --- Fix Version/s: (was: cdc-3.4.0) > No Infomation in Overview at Flink CDC 3.4 > -

[jira] [Updated] (FLINK-37736) Introduce Flink CDC metrics doc

[ https://issues.apache.org/jira/browse/FLINK-37736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37736: --- Fix Version/s: cdc-3.5.0 (was: cdc-3.4.0) > Introduce Flink CDC metrics doc >

[jira] [Updated] (FLINK-37630) Support flink cdc pipeline Yarn session mode

[ https://issues.apache.org/jira/browse/FLINK-37630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37630: --- Fix Version/s: cdc-3.5.0 (was: cdc-3.4.0) > Support flink cdc pipeline Yarn s

[jira] [Updated] (FLINK-37738) [cdc-connector][postgres] Support read changelog as append only mode

[ https://issues.apache.org/jira/browse/FLINK-37738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37738: --- Fix Version/s: cdc-3.5.0 (was: cdc-3.4.0) > [cdc-connector][postgres] Support

[jira] [Resolved] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation

[ https://issues.apache.org/jira/browse/FLINK-37784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37784. Resolution: Fixed Fixed in master: 6af871ebf67dbdcb8fa2443274e392cf04021e4e > [Doc] Remove Duplic

[jira] [Assigned] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation

[ https://issues.apache.org/jira/browse/FLINK-37784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37784: -- Assignee: JunboWang > [Doc] Remove Duplicate Description for > `scan.incremental.snapshot.un

[jira] [Updated] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation

[ https://issues.apache.org/jira/browse/FLINK-37784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37784: --- Fix Version/s: cdc-3.5.0 (was: cdc-3.4.0) > [Doc] Remove Duplicate Descriptio

[jira] [Updated] (FLINK-37784) [Doc] Remove Duplicate Description for `scan.incremental.snapshot.unbounded-chunk-first.enabled` Parameter in Documentation

[ https://issues.apache.org/jira/browse/FLINK-37784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37784: --- Component/s: Documentation > [Doc] Remove Duplicate Description for > `scan.incremental.snapshot.un

[jira] [Comment Edited] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947996#comment-17947996 ] Leonard Xu edited comment on FLINK-37462 at 4/29/25 5:59 AM: -

[jira] [Resolved] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37462. Resolution: Fixed > [Unstable Test Case] > FlinkParallelizedPipelineITCase.testRegularTablesSourc

[jira] [Resolved] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37741. Resolution: Fixed > Severe performance regression of transform operator node > ---

[jira] [Comment Edited] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947995#comment-17947995 ] Leonard Xu edited comment on FLINK-37741 at 4/29/25 5:58 AM: -

[jira] [Comment Edited] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947995#comment-17947995 ] Leonard Xu edited comment on FLINK-37741 at 4/29/25 2:30 AM: -

[jira] [Reopened] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-37741: > Severe performance regression of transform operator node > -

[jira] [Updated] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37741: --- Fix Version/s: cdc-3.5.0 > Severe performance regression of transform operator node > --

[jira] [Commented] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947996#comment-17947996 ] Leonard Xu commented on FLINK-37462: Fixed via master: a9911695cb205a3262be561c47789

[jira] [Reopened] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-37462: > [Unstable Test Case] > FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[jira] [Updated] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37462: --- Fix Version/s: cdc-3.5.0 > [Unstable Test Case] > FlinkParallelizedPipelineITCase.testRegularTables

[jira] [Assigned] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37462: -- Assignee: Xiqian Yu > [Unstable Test Case] > FlinkParallelizedPipelineITCase.testRegularTabl

[jira] [Resolved] (FLINK-37462) [Unstable Test Case] FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism

[ https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37462. Fix Version/s: cdc-3.4.0 Resolution: Fixed > [Unstable Test Case] > FlinkParallelizedPipel

[jira] [Resolved] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37741. Resolution: Fixed via master: 250ab43e185ee39b23c4fb6376b84ea9e6741f58 > Severe performance regre

[jira] [Commented] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947742#comment-17947742 ] Leonard Xu commented on FLINK-37741: +1 for [~loserwang1024] 's point, a ~40% perfor

[jira] [Updated] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37741: --- Priority: Blocker (was: Major) > Severe performance regression of transform operator node > ---

[jira] [Updated] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37741: --- Fix Version/s: cdc-3.4.0 > Severe performance regression of transform operator node > --

[jira] [Updated] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37741: --- Affects Version/s: cdc-3.4.0 > Severe performance regression of transform operator node > --

[jira] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741 ] Leonard Xu deleted comment on FLINK-37741: was (Author: leonard xu): A ~40% performance regression deserves a blocker. > Severe performance regression of transform operator node > --

[jira] [Commented] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947739#comment-17947739 ] Leonard Xu commented on FLINK-37741: A ~40% performance regression deserves a blocke

[jira] [Updated] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37741: --- Description: FLINK-37104 refactored transform module with various code cleanup and logic simplifica

[jira] [Assigned] (FLINK-37741) Severe performance regression of transform operator node

[ https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37741: -- Assignee: yux > Severe performance regression of transform operator node > --

[jira] [Updated] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover

[ https://issues.apache.org/jira/browse/FLINK-37713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37713: --- Fix Version/s: cdc-3.5.0 > SchemaManager was recreated in SchemaRegistry after job failover > -

[jira] [Updated] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover

[ https://issues.apache.org/jira/browse/FLINK-37713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37713: --- Fix Version/s: (was: cdc-3.5.0) > SchemaManager was recreated in SchemaRegistry after job failov

[jira] [Resolved] (FLINK-37709) Add file descriptor usage in default JVM metrics

[ https://issues.apache.org/jira/browse/FLINK-37709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37709. Resolution: Resolved via master: f8b3c4b9a8ce1c6a094fcc0f292faea4bad8806c > Add file descriptor u

[jira] [Assigned] (FLINK-37731) Update dependency of Paimon to 1.1 and add support for Postpone Bucket

[ https://issues.apache.org/jira/browse/FLINK-37731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37731: -- Assignee: Yanquan Lv > Update dependency of Paimon to 1.1 and add support for Postpone Bucket

[jira] [Assigned] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed

[ https://issues.apache.org/jira/browse/FLINK-37453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37453: -- Assignee: Xiqian Yu > Migration Tests / data_stream_migration_test (8, 1.20.1) failed > -

[jira] [Resolved] (FLINK-37453) Migration Tests / data_stream_migration_test (8, 1.20.1) failed

[ https://issues.apache.org/jira/browse/FLINK-37453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37453. Resolution: Fixed Fixed via master: e35180d8f4d6e127f6d0012a5d790f083393b71f > Migration Tests /

[jira] [Resolved] (FLINK-35093) Postgres source connector support SPECIFIC_OFFSETS start up mode from an existed replication slot.

[ https://issues.apache.org/jira/browse/FLINK-35093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35093. Resolution: Implemented Implemented via master: 3f1c893f41ba135cc8c41046423709f0dcd2d973 > Postgr

[jira] [Assigned] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype

[ https://issues.apache.org/jira/browse/FLINK-36973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36973: -- Assignee: hiliuxg > udf dateformat support LocalZonedTimestampData datatype > ---

[jira] [Updated] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype

[ https://issues.apache.org/jira/browse/FLINK-36973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36973: --- External issue URL: (was: https://github.com/apache/flink-cdc/pull/3822) > udf dateformat support

[jira] [Resolved] (FLINK-36973) udf dateformat support LocalZonedTimestampData datatype

[ https://issues.apache.org/jira/browse/FLINK-36973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36973. Fix Version/s: cdc-3.4.0 Resolution: Fixed fixed via master: 37a2e02280d10e7d9b691fbed51cfd

[jira] [Assigned] (FLINK-37479) postgres cdc connector support discover PARTITIONED TABLE

[ https://issues.apache.org/jira/browse/FLINK-37479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37479: -- Assignee: Vinh Pham > postgres cdc connector support discover PARTITIONED TABLE > ---

[jira] [Commented] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data

[ https://issues.apache.org/jira/browse/FLINK-37717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947191#comment-17947191 ] Leonard Xu commented on FLINK-37717: [~vertern] Thanks for your report, Could you po

[jira] [Updated] (FLINK-37717) Stuck occurred during the full synchronization phase, resulting in incomplete synchronization of all data

[ https://issues.apache.org/jira/browse/FLINK-37717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37717: --- Priority: Critical (was: Blocker) > Stuck occurred during the full synchronization phase, resulting

[jira] [Assigned] (FLINK-37726) Read incremental data for existing tables

[ https://issues.apache.org/jira/browse/FLINK-37726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37726: -- Assignee: Yanquan Lv > Read incremental data for existing tables > --

[jira] [Resolved] (FLINK-36742) Filter unacked split for no capture tables when task restore from state

[ https://issues.apache.org/jira/browse/FLINK-36742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36742. Fix Version/s: cdc-3.4.0 (was: cdc-3.3.1) Resolution: Fixed via mast

[jira] [Resolved] (FLINK-37566) table.exclude was invalid in binlog reading phase when scan.binlog.newly-added-table.enabled was true.

[ https://issues.apache.org/jira/browse/FLINK-37566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37566. Fix Version/s: cdc-3.4.0 Resolution: Resolved via master: b89d84fc9cdc107decaa4541e49cae367

[jira] [Updated] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover

[ https://issues.apache.org/jira/browse/FLINK-37713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37713: --- Fix Version/s: cdc-3.4.0 > SchemaManager was recreated in SchemaRegistry after job failover > -

[jira] [Assigned] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover

[ https://issues.apache.org/jira/browse/FLINK-37713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37713: -- Assignee: Yanquan Lv > SchemaManager was recreated in SchemaRegistry after job failover > --

[jira] [Resolved] (FLINK-37713) SchemaManager was recreated in SchemaRegistry after job failover

[ https://issues.apache.org/jira/browse/FLINK-37713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37713. Resolution: Fixed Fixed via master: 612ff5d352b2171b9e218f3e0d0c0b31921a3429 > SchemaManager was

[jira] [Assigned] (FLINK-36546) Handle batch sources in DataSinkTranslator

[ https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36546: -- Assignee: Sergei Morozov > Handle batch sources in DataSinkTranslator > -

[jira] [Updated] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform

[ https://issues.apache.org/jira/browse/FLINK-37104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37104: --- Issue Type: Technical Debt (was: Improvement) > Code simplification and cleaning related to Flink C

[jira] [Resolved] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform

[ https://issues.apache.org/jira/browse/FLINK-37104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37104. Fix Version/s: cdc-3.4.0 Resolution: Resolved Resolved via master: 4bc736643c9d047c7747101c

[jira] [Resolved] (FLINK-34874) [MongoDB] Support initial.snapshotting.pipeline related configs in table api

[ https://issues.apache.org/jira/browse/FLINK-34874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-34874. Fix Version/s: cdc-3.4.0 Resolution: Resolved via master: 19934445800cc8931ade34b5741cb69f8

[jira] [Assigned] (FLINK-34874) [MongoDB] Support initial.snapshotting.pipeline related configs in table api

[ https://issues.apache.org/jira/browse/FLINK-34874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-34874: -- Assignee: Runkang He > [MongoDB] Support initial.snapshotting.pipeline related configs in tab

[jira] [Updated] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large.

[ https://issues.apache.org/jira/browse/FLINK-36793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-36793: --- Issue Type: Bug (was: Improvement) > There is a problem with the block splitter logic of Oracle CDC

[jira] [Resolved] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large.

[ https://issues.apache.org/jira/browse/FLINK-36793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36793. Fix Version/s: cdc-3.4.0 Resolution: Fixed Fixed via master: 2729ad02d7a44f5b1d3af414a17324

[jira] [Assigned] (FLINK-36793) There is a problem with the block splitter logic of Oracle CDC incremental snapshot, causing the split slice to be too large.

[ https://issues.apache.org/jira/browse/FLINK-36793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-36793: -- Assignee: 林健昌 > There is a problem with the block splitter logic of Oracle CDC incremental >

[jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name

[ https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34961: --- Fix Version/s: jdbc-4.1.0 (was: jdbc-3.3.0) > GitHub Actions runner statistcs

[jira] [Resolved] (FLINK-35152) Flink CDC Doris Sink Auto create table event should support setting auto partition fields for each table

[ https://issues.apache.org/jira/browse/FLINK-35152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35152. Resolution: Implemented Implemented via master: e7760d444af770ae5f549afd0a05754f07a9683f > Flink

[jira] [Assigned] (FLINK-35152) Flink CDC Doris Sink Auto create table event should support setting auto partition fields for each table

[ https://issues.apache.org/jira/browse/FLINK-35152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35152: -- Assignee: linqigeng > Flink CDC Doris Sink Auto create table event should support setting au

[jira] [Assigned] (FLINK-37712) Met TableNotFound exception when reading ParallelMetadataSource to Paimon Sink

[ https://issues.apache.org/jira/browse/FLINK-37712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37712: -- Assignee: Yanquan Lv > Met TableNotFound exception when reading ParallelMetadataSource to Pai

[jira] [Assigned] (FLINK-37709) Add file descriptor usage in default JVM metrics

[ https://issues.apache.org/jira/browse/FLINK-37709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37709: -- Assignee: Zhenqiu Huang > Add file descriptor usage in default JVM metrics > ---

[jira] [Resolved] (FLINK-36931) FlinkCDC YAML supports synchronizing the full amount of data of the entire database in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-36931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-36931. Fix Version/s: cdc-3.4.0 Resolution: Implemented Supported via master: 61702a6a9d729b1b

[jira] [Resolved] (FLINK-37706) [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Caused by: java.sql.SQLException: Server out of disk space

[ https://issues.apache.org/jira/browse/FLINK-37706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37706. Resolution: Fixed via master: 4cf54c61f9f9283ba1138ffc0179f53f6b67ce3f > [Flink CDC] Oceanbase Oc

[jira] [Commented] (FLINK-37706) [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Caused by: java.sql.SQLException: Server out of disk space

[ https://issues.apache.org/jira/browse/FLINK-37706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946108#comment-17946108 ] Leonard Xu commented on FLINK-37706: We used latest OB docker version in test, but r

[jira] [Assigned] (FLINK-37706) [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Caused by: java.sql.SQLException: Server out of disk space

[ https://issues.apache.org/jira/browse/FLINK-37706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37706: -- Assignee: Leonard Xu > [Flink CDC] Oceanbase OceanBaseMetadataApplierTest failed due to Cause

[jira] [Assigned] (FLINK-37507) MySQL CDC captures common-prefix database accidentally when scan.binlog.newly-added-table option is enabled

[ https://issues.apache.org/jira/browse/FLINK-37507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37507: -- Assignee: yux > MySQL CDC captures common-prefix database accidentally when > scan.binlog.ne

[jira] [Resolved] (FLINK-37507) MySQL CDC captures common-prefix database accidentally when scan.binlog.newly-added-table option is enabled

[ https://issues.apache.org/jira/browse/FLINK-37507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37507. Fix Version/s: cdc-3.4.0 Resolution: Fixed fixed via master: 72345f0ec73c9cc3013d2804c90202

[jira] [Assigned] (FLINK-37509) Increment scan source no need to buffer data when enable skipping backfill.

[ https://issues.apache.org/jira/browse/FLINK-37509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-37509: -- Assignee: Hongshun Wang > Increment scan source no need to buffer data when enable skipping b

[jira] [Resolved] (FLINK-37578) CDC Pipeline distributed schema evolution topology with bad internal state

[ https://issues.apache.org/jira/browse/FLINK-37578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-37578. Resolution: Implemented Fixed via master: 47433993575d222808eb9cabe17b63c79270ae3d > CDC Pipeline

[jira] [Updated] (FLINK-37578) CDC Pipeline distributed schema evolution topology with bad internal state

[ https://issues.apache.org/jira/browse/FLINK-37578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-37578: --- Fix Version/s: cdc-3.4.0 > CDC Pipeline distributed schema evolution topology with bad internal stat

  1   2   3   4   5   6   7   8   9   10   >