[jira] [Created] (FLINK-35538) pipeline sink support caseSensitive

melin created FLINK-35538: - Summary: pipeline sink support caseSensitive Key: FLINK-35538 URL: https://issues.apache.org/jira/browse/FLINK-35538 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35511) Enhance metrics. The incremental and full phases count the number of records separately

melin created FLINK-35511: - Summary: Enhance metrics. The incremental and full phases count the number of records separately Key: FLINK-35511 URL: https://issues.apache.org/jira/browse/FLINK-35511 Project:

[jira] [Created] (FLINK-35478) Pipeline sink Unified primary.key parameter

melin created FLINK-35478: - Summary: Pipeline sink Unified primary.key parameter Key: FLINK-35478 URL: https://issues.apache.org/jira/browse/FLINK-35478 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

[ https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35417: -- Description: flink is widely used in data integration scenarios, where a single concurrency is not high, and

[jira] [Updated] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

[ https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35417: -- Description: Spark is used in data integration scenarios (such as reading data from mysql and writing data to

[jira] [Commented] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

[ https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848676#comment-17848676 ] melin commented on FLINK-35417: --- The current deployment model has encountered challenges in many projects.

[jira] [Created] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

melin created FLINK-35417: - Summary: JobManager and TaskManager support merging and run in a single process Key: FLINK-35417 URL: https://issues.apache.org/jira/browse/FLINK-35417 Project: Flink

[jira] [Created] (FLINK-35394) paimon pipeline support dynamic bucket

melin created FLINK-35394: - Summary: paimon pipeline support dynamic bucket Key: FLINK-35394 URL: https://issues.apache.org/jira/browse/FLINK-35394 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35393) Support flink kafka catalog

melin created FLINK-35393: - Summary: Support flink kafka catalog Key: FLINK-35393 URL: https://issues.apache.org/jira/browse/FLINK-35393 Project: Flink Issue Type: New Feature Components:

[jira] [Updated] (FLINK-35303) Support logical deletion of data

[ https://issues.apache.org/jira/browse/FLINK-35303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35303: -- Affects Version/s: cdc-3.2.0 > Support logical deletion of data > - > >

[jira] [Created] (FLINK-35329) Support modify table/column comments

melin created FLINK-35329: - Summary: Support modify table/column comments Key: FLINK-35329 URL: https://issues.apache.org/jira/browse/FLINK-35329 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-35303) Support logical deletion of data

[ https://issues.apache.org/jira/browse/FLINK-35303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35303: -- Summary: Support logical deletion of data (was: Support logical deletion of datax) > Support logical

[jira] [Created] (FLINK-35303) Support logical deletion of datax

melin created FLINK-35303: - Summary: Support logical deletion of datax Key: FLINK-35303 URL: https://issues.apache.org/jira/browse/FLINK-35303 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35248) Support table/column comment to modify DDL

melin created FLINK-35248: - Summary: Support table/column comment to modify DDL Key: FLINK-35248 URL: https://issues.apache.org/jira/browse/FLINK-35248 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35179) add postgres pipeline data sink connector

melin created FLINK-35179: - Summary: add postgres pipeline data sink connector Key: FLINK-35179 URL: https://issues.apache.org/jira/browse/FLINK-35179 Project: Flink Issue Type: New Feature

[jira] [Commented] (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:comment-tabpanel=17839198#comment-17839198 ] melin commented on FLINK-35144: --- Yes, the business system database consists of multiple database

[jira] [Commented] (FLINK-35172) DDL statement is added to the Schema Change Event

[ https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838924#comment-17838924 ] melin commented on FLINK-35172: --- cc [~1365976...@qq.com] > DDL statement is added to the Schema Change

[jira] [Updated] (FLINK-35172) DDL statement is added to the Schema Change Event

[ https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35172: -- Description: The current implementation of the [kafka pipeline data sink connector

[jira] [Created] (FLINK-35172) DDL statement is added to the Schema Change Event

melin created FLINK-35172: - Summary: DDL statement is added to the Schema Change Event Key: FLINK-35172 URL: https://issues.apache.org/jira/browse/FLINK-35172 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector

[ https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35104: -- Description: There is already a kafka pipeline data sink connector, and there should also be a kafka

[jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector

[ https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35104: -- Description: There is already a kafka pipeline data sink connector, and there should also be a kafka

[jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector

[ https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35104: -- Description: There is already a kafka pipeline data sink connector :

[jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector

[ https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35104: -- Description: There is already a kafka pipeline data sink connector :

[jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector

[ https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35104: -- Description: There is already a [kafka pipeline data sink

[jira] [Updated] (FLINK-35104) Add kafka pipeline data source connector

[ https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-35104: -- Description: First collect cdc data in real time and write it to kafka, then write it to multiple different

[jira] [Created] (FLINK-35104) Add kafka pipeline data source connector

melin created FLINK-35104: - Summary: Add kafka pipeline data source connector Key: FLINK-35104 URL: https://issues.apache.org/jira/browse/FLINK-35104 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-35099) Support for multiple datasources

melin created FLINK-35099: - Summary: Support for multiple datasources Key: FLINK-35099 URL: https://issues.apache.org/jira/browse/FLINK-35099 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-32766) Support kafka catalog

melin created FLINK-32766: - Summary: Support kafka catalog Key: FLINK-32766 URL: https://issues.apache.org/jira/browse/FLINK-32766 Project: Flink Issue Type: New Feature Reporter: melin

[jira] [Created] (FLINK-32251) flink jdbc catalog cannot add parameters to url

melin created FLINK-32251: - Summary: flink jdbc catalog cannot add parameters to url Key: FLINK-32251 URL: https://issues.apache.org/jira/browse/FLINK-32251 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-32163) Support the same application run multiple jobs in HA mode

melin created FLINK-32163: - Summary: Support the same application run multiple jobs in HA mode Key: FLINK-32163 URL: https://issues.apache.org/jira/browse/FLINK-32163 Project: Flink Issue Type: New

[jira] [Created] (FLINK-32125) Support Unified job submission API

melin created FLINK-32125: - Summary: Support Unified job submission API Key: FLINK-32125 URL: https://issues.apache.org/jira/browse/FLINK-32125 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-29734) Support authentication in the Flink SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-29734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686197#comment-17686197 ] melin commented on FLINK-29734: --- (?) > Support authentication in the Flink SQL Gateway >

[jira] [Commented] (FLINK-25402) FLIP-198: Working directory for Flink processes

[ https://issues.apache.org/jira/browse/FLINK-25402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684429#comment-17684429 ] melin commented on FLINK-25402: --- When a job is submitted, can add files to the Working directory? spark

[jira] [Commented] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638440#comment-17638440 ] melin commented on FLINK-30126: --- Spark also does not support dynamic catalog, which is created through aop

[jira] [Updated] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-30126: -- Attachment: image-2022-11-25-09-12-59-477.png > Delay registration of the catalog, register the catalog as

[jira] [Updated] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

[ https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-30126: -- Description: Data platform has registered many relational database data sources such as mysql, data source

[jira] [Created] (FLINK-30126) Delay registration of the catalog, register the catalog as needed

melin created FLINK-30126: - Summary: Delay registration of the catalog, register the catalog as needed Key: FLINK-30126 URL: https://issues.apache.org/jira/browse/FLINK-30126 Project: Flink Issue

[jira] [Updated] (FLINK-30123) Optimize ApplicationDeployer API design

[ https://issues.apache.org/jira/browse/FLINK-30123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-30123: -- Description: The task is submitted by ApplicationDeployer api, and the run is synchronous and waiting for

[jira] [Created] (FLINK-30123) Optimize ApplicationDeployer API design

melin created FLINK-30123: - Summary: Optimize ApplicationDeployer API design Key: FLINK-30123 URL: https://issues.apache.org/jira/browse/FLINK-30123 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-30121) Support Stored procedures

melin created FLINK-30121: - Summary: Support Stored procedures Key: FLINK-30121 URL: https://issues.apache.org/jira/browse/FLINK-30121 Project: Flink Issue Type: New Feature Components:

[jira] [Updated] (FLINK-25760) Support custom SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-25760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-25760: -- Description: Supports custom SQL syntax, similar to Spark Extensions Feature. Custom SQL syntax can be

[jira] [Updated] (FLINK-25760) Support custom SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-25760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] melin updated FLINK-25760: -- Summary: Support custom SQL syntax (was: Support for extended SQL syntax) > Support custom SQL syntax >

[jira] [Created] (FLINK-25760) Support for extended SQL syntax

melin created FLINK-25760: - Summary: Support for extended SQL syntax Key: FLINK-25760 URL: https://issues.apache.org/jira/browse/FLINK-25760 Project: Flink Issue Type: Improvement