[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 Repo

[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 F

[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-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-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 Componen

[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-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] [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] [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-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 Compon

[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 Comp

[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: C

[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 Co

[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 Iss

[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] [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: Fl

[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 Compo

[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 Reporte

[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: Tab

[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-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 Ty

[jira] [Created] (FLINK-35664) Flink CDC pipeline transform supports mask function

melin created FLINK-35664: - Summary: Flink CDC pipeline transform supports mask function Key: FLINK-35664 URL: https://issues.apache.org/jira/browse/FLINK-35664 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35714) Flink CDC pipeline sink support Automatic create tag

melin created FLINK-35714: - Summary: Flink CDC pipeline sink support Automatic create tag Key: FLINK-35714 URL: https://issues.apache.org/jira/browse/FLINK-35714 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-36107) schema event support custom callback

melin created FLINK-36107: - Summary: schema event support custom callback Key: FLINK-36107 URL: https://issues.apache.org/jira/browse/FLINK-36107 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-36524) upgrade paimon 0.9.0

melin created FLINK-36524: - Summary: upgrade paimon 0.9.0 Key: FLINK-36524 URL: https://issues.apache.org/jira/browse/FLINK-36524 Project: Flink Issue Type: Improvement Components: Flink CD

[jira] [Created] (FLINK-36313) Support pipeline sink hudi

melin created FLINK-36313: - Summary: Support pipeline sink hudi Key: FLINK-36313 URL: https://issues.apache.org/jira/browse/FLINK-36313 Project: Flink Issue Type: Improvement Components: Fl

[jira] [Created] (FLINK-36814) Flink CDC Support Mutil Datasource

melin created FLINK-36814: - Summary: Flink CDC Support Mutil Datasource Key: FLINK-36814 URL: https://issues.apache.org/jira/browse/FLINK-36814 Project: Flink Issue Type: New Feature Compon

[jira] [Created] (FLINK-36737) flink-shaded-hadoop-2-uber contains the common io version incompatible with the flink client

melin created FLINK-36737: - Summary: flink-shaded-hadoop-2-uber contains the common io version incompatible with the flink client Key: FLINK-36737 URL: https://issues.apache.org/jira/browse/FLINK-36737 Projec

[jira] [Created] (FLINK-37118) Enhance flink cdc metrics

melin created FLINK-37118: - Summary: Enhance flink cdc metrics Key: FLINK-37118 URL: https://issues.apache.org/jira/browse/FLINK-37118 Project: Flink Issue Type: New Feature Components: Fli