Re:[Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off

2025-05-29 Thread MOBIN
+1, thanks for driving this release! Looking forward to the arrival of version 3.5! At 2025-05-27 11:36:40, "Yanquan Lv" wrote: >Hi devs, > >As FlinkCDC 3.4 was released recently, it's a good time to kick off the >upcoming Flink CDC 3.5 release cycle. > >In the past two major versions, we ha

[jira] [Created] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly

2025-05-28 Thread MOBIN (Jira)
MOBIN created FLINK-37860: - Summary: [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly Key: FLINK-37860 URL: https://issues.apache.org/jira/browse/FLINK-37860 Project

[jira] [Created] (FLINK-37839) Add COPYFILE_DISABLE=1 parameter to avoid generating ._* files when using mac tar to package

2025-05-23 Thread MOBIN (Jira)
MOBIN created FLINK-37839: - Summary: Add COPYFILE_DISABLE=1 parameter to avoid generating ._* files when using mac tar to package Key: FLINK-37839 URL: https://issues.apache.org/jira/browse/FLINK-37839

[jira] [Created] (FLINK-37781) Add elasticsearch lookup join document

2025-05-12 Thread MOBIN (Jira)
MOBIN created FLINK-37781: - Summary: Add elasticsearch lookup join document Key: FLINK-37781 URL: https://issues.apache.org/jira/browse/FLINK-37781 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37739) flink-conf is not obtained in local mode

2025-04-27 Thread MOBIN (Jira)
MOBIN created FLINK-37739: - Summary: flink-conf is not obtained in local mode Key: FLINK-37739 URL: https://issues.apache.org/jira/browse/FLINK-37739 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37348) [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column

2025-02-18 Thread MOBIN (Jira)
MOBIN created FLINK-37348: - Summary: [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column Key: FLINK-37348 URL: https://issues.apache.org/jira/browse/FLINK-37348

[jira] [Created] (FLINK-37334) Fix mysql's add column after event becomes add column last

2025-02-17 Thread MOBIN (Jira)
MOBIN created FLINK-37334: - Summary: Fix mysql's add column after event becomes add column last Key: FLINK-37334 URL: https://issues.apache.org/jira/browse/FLINK-37334 Project: Flink Issue Type

[jira] [Created] (FLINK-37132) Add schema validation in Multi Transform

2025-01-14 Thread MOBIN (Jira)
MOBIN created FLINK-37132: - Summary: Add schema validation in Multi Transform Key: FLINK-37132 URL: https://issues.apache.org/jira/browse/FLINK-37132 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37012) Fix exception caused by MetadataColumns causing argument type mismatch

2025-01-06 Thread MOBIN (Jira)
MOBIN created FLINK-37012: - Summary: Fix exception caused by MetadataColumns causing argument type mismatch Key: FLINK-37012 URL: https://issues.apache.org/jira/browse/FLINK-37012 Project: Flink

[jira] [Created] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options

2024-12-24 Thread MOBIN (Jira)
MOBIN created FLINK-36958: - Summary: Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options Key: FLINK-36958 URL: https://issues.apache.org/jira/browse/FLINK-36958 Project

[jira] [Created] (FLINK-36858) [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug

2024-12-05 Thread MOBIN (Jira)
MOBIN created FLINK-36858: - Summary: [pipeline-kafka] JsonRowDataSerializationSchema compatibility bug Key: FLINK-36858 URL: https://issues.apache.org/jira/browse/FLINK-36858 Project: Flink Issue

[jira] [Created] (FLINK-36754) When projection is empty or null, it is treated as an asterisk

2024-11-20 Thread MOBIN (Jira)
MOBIN created FLINK-36754: - Summary: When projection is empty or null, it is treated as an asterisk Key: FLINK-36754 URL: https://issues.apache.org/jira/browse/FLINK-36754 Project: Flink Issue Type

[jira] [Created] (FLINK-36632) When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data

2024-10-30 Thread MOBIN (Jira)
MOBIN created FLINK-36632: - Summary: When scan.startup.mode is not initial and restart with savepoint, newly add-table will not synchronize snapshot data Key: FLINK-36632 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-36597) Optimize SnapshotSplitAssigner error log output

2024-10-24 Thread MOBIN (Jira)
MOBIN created FLINK-36597: - Summary: Optimize SnapshotSplitAssigner error log output Key: FLINK-36597 URL: https://issues.apache.org/jira/browse/FLINK-36597 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36580) Using debezium.column.exclude.list causes job failure

2024-10-22 Thread MOBIN (Jira)
MOBIN created FLINK-36580: - Summary: Using debezium.column.exclude.list causes job failure Key: FLINK-36580 URL: https://issues.apache.org/jira/browse/FLINK-36580 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36188) HBase disable buffer flush lose efficacy

2024-08-30 Thread MOBIN (Jira)
MOBIN created FLINK-36188: - Summary: HBase disable buffer flush lose efficacy Key: FLINK-36188 URL: https://issues.apache.org/jira/browse/FLINK-36188 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36111) fix: adjust MultiTableCommittableChannelComputer Topology name

2024-08-20 Thread MOBIN (Jira)
MOBIN created FLINK-36111: - Summary: fix: adjust MultiTableCommittableChannelComputer Topology name Key: FLINK-36111 URL: https://issues.apache.org/jira/browse/FLINK-36111 Project: Flink Issue

[jira] [Created] (FLINK-35936) paimon cdc schema evolution failure when restart job

2024-07-30 Thread MOBIN (Jira)
MOBIN created FLINK-35936: - Summary: paimon cdc schema evolution failure when restart job Key: FLINK-35936 URL: https://issues.apache.org/jira/browse/FLINK-35936 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35058) Encountered change event for table db.table whose schema isn't known to this connector

2024-04-08 Thread MOBIN (Jira)
MOBIN created FLINK-35058: - Summary: Encountered change event for table db.table whose schema isn't known to this connector Key: FLINK-35058 URL: https://issues.apache.org/jira/browse/FLINK-35058 Pr

[jira] [Created] (FLINK-33971) Specifies whether to use HBase table that supports dynamic columns.

2024-01-02 Thread MOBIN (Jira)
MOBIN created FLINK-33971: - Summary: Specifies whether to use HBase table that supports dynamic columns. Key: FLINK-33971 URL: https://issues.apache.org/jira/browse/FLINK-33971 Project: Flink Issue

[jira] [Created] (FLINK-29252) Support create table-store table with 'connector'='table-store'

2022-09-09 Thread MOBIN (Jira)
MOBIN created FLINK-29252: - Summary: Support create table-store table with 'connector'='table-store' Key: FLINK-29252 URL: https://issues.apache.org/jira/browse/FLINK-29252 Project: F

[jira] [Created] (FLINK-29213) Pretty schema json file

2022-09-06 Thread MOBIN (Jira)
MOBIN created FLINK-29213: - Summary: Pretty schema json file Key: FLINK-29213 URL: https://issues.apache.org/jira/browse/FLINK-29213 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-23195) No value for kafka metrics in Flink Web ui

2021-06-30 Thread MOBIN (Jira)
MOBIN created FLINK-23195: - Summary: No value for kafka metrics in Flink Web ui Key: FLINK-23195 URL: https://issues.apache.org/jira/browse/FLINK-23195 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23026) OVER WINDOWS function lost data

2021-06-17 Thread MOBIN (Jira)
MOBIN created FLINK-23026: - Summary: OVER WINDOWS function lost data Key: FLINK-23026 URL: https://issues.apache.org/jira/browse/FLINK-23026 Project: Flink Issue Type: Bug Components