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
[
https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856667#comment-17856667
]
melin commented on FLINK-35664:
---
yes, see hive mask function:
[https://cwiki.apache.org/c
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
[
https://issues.apache.org/jira/browse/FLINK-35714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860933#comment-17860933
]
melin commented on FLINK-35714:
---
cc [~kunni]
> Flink CDC pipeline sink support Automatic
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
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
[
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 d
[
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|[https://github.com/apache/flink-cdc/pull
[
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 :
[https://github.com/apache/flink-cdc/pul
[
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 :
[https://github.com/apache/flink-cdc/pul
[
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 pipeline
[
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 pipeline
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
[
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
|https://github.com/apache
[
https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838924#comment-17838924
]
melin commented on FLINK-35172:
---
cc [~1365976...@qq.com]
> DDL statement is added to the
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839198#comment-17839198
]
melin commented on FLINK-35144:
---
Yes, the business system database consists of multiple da
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
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
[
https://issues.apache.org/jira/browse/FLINK-36107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-36107:
--
Description:
User-defined callback is supported. sink obtains the schema event and invokes
the callback imple
[
https://issues.apache.org/jira/browse/FLINK-36107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17875380#comment-17875380
]
melin commented on FLINK-36107:
---
cc [~xiqian_yu]
> schema event support custom callback
[
https://issues.apache.org/jira/browse/FLINK-36107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-36107:
--
Description:
User-defined callback is supported. sink obtains the schema event and invokes
the callback imple
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-34257:
--
Attachment: image-2024-08-26-19-53-40-349.png
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-34257:
--
Attachment: image-2024-08-26-19-55-06-927.png
> Update Flink YAML Parser to Support YAML 1.2 Specification
>
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876695#comment-17876695
]
melin commented on FLINK-34257:
---
添加 -Dkubernetes.container.image.pull-secrets=docker-reg-
[
https://issues.apache.org/jira/browse/FLINK-34257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876896#comment-17876896
]
melin commented on FLINK-34257:
---
Thank you! The input format problem has been solved, it i
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
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
[
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 dele
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
[
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
> -
>
>
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-35417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848676#comment-17848676
]
melin commented on FLINK-35417:
---
The current deployment model has encountered challenges i
[
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
[
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-25402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684429#comment-17684429
]
melin commented on FLINK-25402:
---
When a job is submitted, can add files to the Working dir
[
https://issues.apache.org/jira/browse/FLINK-29734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686197#comment-17686197
]
melin commented on FLINK-29734:
---
(?)
> Support authentication in the Flink SQL Gateway
>
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
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
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
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
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
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
[
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 the
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
[
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 cod
[
https://issues.apache.org/jira/browse/FLINK-30126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638440#comment-17638440
]
melin commented on FLINK-30126:
---
Spark also does not support dynamic catalog, which is cre
[
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 nee
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
[
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
> -
[
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 implem
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
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-32315:
--
Attachment: image-2024-10-29-11-32-25-979.png
> Support local file upload in K8s mode
> --
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893685#comment-17893685
]
melin edited comment on FLINK-32315 at 10/29/24 3:34 AM:
-
Can't
[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893685#comment-17893685
]
melin commented on FLINK-32315:
---
./bin/flink run-application \
--target kubernetes-app
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
[
https://issues.apache.org/jira/browse/FLINK-32766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885911#comment-17885911
]
melin commented on FLINK-32766:
---
[~loserwang1024] Well, thank you for developing this fea
[
https://issues.apache.org/jira/browse/FLINK-32766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-32766:
--
Description:
Support kafka catalog
ref:
https://www.alibabacloud.com/help/en/flink/user-guide/manage-kafka-js
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
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-36737:
--
Attachment: image-2024-11-17-15-09-46-502.png
> flink-shaded-hadoop-2-uber contains the common io version inco
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
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899000#comment-17899000
]
melin commented on FLINK-36737:
---
cc [~fcsaky]
> flink-shaded-hadoop-2-uber contains the
[
https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899001#comment-17899001
]
melin commented on FLINK-28915:
---
flink-shaded-hadoop-2-uber contains the common io version
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899008#comment-17899008
]
melin edited comment on FLINK-36737 at 11/17/24 2:50 PM:
-
[~hack
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-36737:
--
Description:
The current version of flink relies on commons io version 1.15.1. If you add
flink-shaded- hadoo
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-36737:
--
Description:
The current version of flink relies on commons io version 1.15.1. If you add
flink-shaded- hadoo
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899008#comment-17899008
]
melin commented on FLINK-36737:
---
[~hackergin] flink on k8s, without HADOOP_CLASSPATH, it
[
https://issues.apache.org/jira/browse/FLINK-36737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17899014#comment-17899014
]
melin commented on FLINK-36737:
---
The spark download package includes hadoop * hive jar for
[
https://issues.apache.org/jira/browse/FLINK-37118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-37118:
--
Fix Version/s: cdc-3.4.0
> Enhance flink cdc metrics
> -
>
> Key: FLIN
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915967#comment-17915967
]
melin commented on FLINK-36061:
---
Add compaction optimization? For example, commit executes
[
https://issues.apache.org/jira/browse/FLINK-36061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915967#comment-17915967
]
melin edited comment on FLINK-36061 at 1/22/25 8:57 AM:
Add comp
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
76 matches
Mail list logo
