Proposal to Add a JDBC Sink Plugin to Flink-CDC-Pipeline

2024-05-15 Thread Jerry
Hi all My name is ZhengjunZhou, an user and developer of FlinkCDC. In my recent projects, I realized that we could enhance the capabilities of Flink-CDC-Pipeline by introducing a JDBC Sink plugin, enabling FlinkCDC to directly output change data capture (CDC) to various JDBC-supported database sys

[DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline

2024-05-15 Thread Jerry
Hi all My name is ZhengjunZhou, an user and developer of FlinkCDC. In my recent projects, I realized that we could enhance the capabilities of Flink-CDC-Pipeline by introducing a JDBC Sink plugin, enabling FlinkCDC to directly output change data capture (CDC) to various JDBC-supported database syst

Re: [DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline

2024-06-02 Thread Jerry
table structure change process. Yanquan Lv 于2024年5月22日周三 21:11写道： > Thanks jerry for driving this, JDBC sink for CDC pipeline is indeed a high > demand in the community. > > I have one concern: > Some databases that use jdbc, such as mysql, may be time-consuming to > perform

Re: [DISCUSS] Add a JDBC Sink Plugin to Flink-CDC-Pipeline

2024-06-14 Thread Jerry
The content has been edited in FLIP format, but I don't have wiki permissions and can't create a wiki document. https://docs.google.com/document/d/1bgKV9Teq8ktHZOAJ7EKzgSqP11Q4ZT2EM8BndOtDgy0/edit Leonard Xu 于2024年5月21日周二 22:50写道： > Thanks Jerry for kicking off this thread, t

Flink-connector-jdbc v3.2.0 support flink 1.17.x?

2024-06-24 Thread Jerry
Can Flink-connector-jdbc v3.2.0 support flink 1.17.x?

Re: Flink CDC 3.3 Kick Off Proposal

2024-09-27 Thread Jerry
Thanks yanquan for kicking off the next major release! I’d like to add JDBC sink plugin to Flink-CDC-Pipeline and add support for engines such as mysql and postgresSQL [1] https://docs.google.com/document/d/1bgKV9Teq8ktHZOAJ7EKzgSqP11Q4ZT2EM8BndOtDgy0/edit [2] https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21582) COALESCE not works when cast a variable return null

2021-03-03 Thread Jerry (Jira)
Jerry created FLINK-21582: - Summary: COALESCE not works when cast a variable return null Key: FLINK-21582 URL: https://issues.apache.org/jira/browse/FLINK-21582 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Boyang Jerry Peng (JIRA)
Boyang Jerry Peng created FLINK-2585: Summary: KafkaSource not working Key: FLINK-2585 URL: https://issues.apache.org/jira/browse/FLINK-2585 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

2015-09-02 Thread Boyang Jerry Peng (JIRA)
Boyang Jerry Peng created FLINK-2610: Summary: run method in AbstractStormSpoutWrapper causes NPE Key: FLINK-2610 URL: https://issues.apache.org/jira/browse/FLINK-2610 Project: Flink

[jira] [Created] (FLINK-19468) Metrics not returned when data stream / operator name contains "+"

2020-09-29 Thread Boyang Jerry Peng (Jira)
Boyang Jerry Peng created FLINK-19468: - Summary: Metrics not returned when data stream / operator name contains "+" Key: FLINK-19468 URL: https://issues.apache.org/jira/browse/FLINK-19468