SeungMin

In tail plugin, position data in pos_file often was deleted? disappear?

6

### Describe the bug The postition information of each file in pos_file disappears. And only empty pos_file remain. After that, several phenomena occur. Such as "Unparsable line in pos_file: 000000000796950c"...

We **implemented a notification DDL with GTIDs and skip DDL and after all queries after DDL** Our team use Flink CDC to perform MySql CDC. But since our team sources...

EDIT contributor in flink cdc 3.1.0 release notes

1

i changed my git nickname from L to SeungMin. so i want to change contributor name in release notes.

[FLINK-36027][cdc-connector][mysql] numRecordsOut/numRecordsOutRate metrics for each OperationType

5

Added numRecordsOut/numRecordsOutRate metrics for each OperationType `INSERT`, `UPDATE`, `DELETE`. Removed table identifier from metrics name. With monitoring tools such as prometheus, we can distinguish flink job, db, and table using...

## Problem When used with Kafka connect, there are cases where null values ​in the record ​are changed to default values. In kafka-connect library v3.5, [`replace.null.with.default` option was added ](https://issues.apache.org/jira/browse/KAFKA-8713)to...

[SUPPORT] Multiple flink jobs in same Flink Sesssion cluster

2

**_Tips before filing an issue_** - Have you gone through our [FAQs](https://hudi.apache.org/learn/faq/)? - Join the mailing list to engage in conversations and get faster support at [email protected]. - If you...

[SUPPORT] Flink inline clustering "Metadata is empty for partition: ~~"

7

**_Tips before filing an issue_** - Have you gone through our [FAQs](https://hudi.apache.org/learn/faq/)? - Join the mailing list to engage in conversations and get faster support at [email protected]. - If you...