[jira] [Created] (FLINK-36586) Upgrade Flink CDC dependency to Flink 1.19+

ZhengYu Chen created FLINK-36586: Summary: Upgrade Flink CDC dependency to Flink 1.19+ Key: FLINK-36586 URL: https://issues.apache.org/jira/browse/FLINK-36586 Project: Flink Issue Type: New

[jira] [Created] (FLINK-36061) Support Apache iceberg for pipeline connector

ZhengYu Chen created FLINK-36061: Summary: Support Apache iceberg for pipeline connector Key: FLINK-36061 URL: https://issues.apache.org/jira/browse/FLINK-36061 Project: Flink Issue Type

[jira] [Created] (FLINK-35592) MysqlDebeziumTimeConverter miss timezone convert to timestamp

ZhengYu Chen created FLINK-35592: Summary: MysqlDebeziumTimeConverter miss timezone convert to timestamp Key: FLINK-35592 URL: https://issues.apache.org/jira/browse/FLINK-35592 Project: Flink

[jira] [Created] (FLINK-35173) Debezium Custom Time Serializer

ZhengYu Chen created FLINK-35173: Summary: Debezium Custom Time Serializer Key: FLINK-35173 URL: https://issues.apache.org/jira/browse/FLINK-35173 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34904) [Feature] submit Flink CDC pipeline job to yarn application cluster.

ZhengYu Chen created FLINK-34904: Summary: [Feature] submit Flink CDC pipeline job to yarn application cluster. Key: FLINK-34904 URL: https://issues.apache.org/jira/browse/FLINK-34904 Project: Flink

[DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

Hi all, We would like to start a discussion thread on FLIP-256 Support Job Dynamic Parameter With Flink Rest Api [1] After the user submits the jar package, running a job through restap

RE: [DISCUSS] FLIP-223: Implement standalone mode support in the kubernetes operator

I only see LAST_STATE support for zookeeper here（FLINK-27416 ）, but I don't see anything about k8s. What do you think about this? I am very willing to move this work forward -- Best ConradJam

RE: [DISCUSS] Release Kubernetes operator 1.0.1

+1 for the patch release. -- Best ConradJam

RE: [DISCUSS] FLIP-212: Introduce Flink Kubernetes Operator

Hi, regarding the construction of k8s Flink Operator, I have already completed some functions. I hope to contribute this part of the functions and discuss with the community how to improve it. How should I start? So far I have seen that the component has no operation persistence. Should we persist