flink-cdc

flink-cdc copied to clipboard

I created a version that fixes itself automatically, but I can't verify it because I don't know how.

911432

[FLINK-36406] Close MetadataApplier when the job stops

1

This pull request implements closing `MetadataApplier` when the job stops. This allows `MetadataApplier` implementations to release the resources that they may use to apply schema changes (e.g. a JDBC connection)....

morozov

[FLINK-35982] Fix transform metadata config doesn't work if no projection block was provided

1

This closes FLINK-35982. One may readjust source table primary keys, partition keys, table options by specifying them in a Transform block like this: ```yaml transform: - source-table: db.tbl projection: '*'...

yuxiqian

[FLINK-36408] Fix MySQL pipeline connector failed to parse FLOAT type with precision

1

Currently, MySQL SourceRecordEmitter treats `FLOAT(x)` (float with explicit precision) as a `DOUBLE`, but pipeline `MetadataAccessor` reports a plain "FLOAT", which causes discrepancy and corrupted deserialized data. This bug should be...

yuxiqian

[FLINK-36397][cdc-connector][mysql] Obtain the high watermark offset and table data in the same transaction during the Snapshot phase

1

This closes [[FLINK-36397](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-36397)] Obtain the high watermark offset and table data in the same transaction during the Snapshot phase,This ensures that the data retrieved is consistent and avoids any potential...

qiaozongmi

[minor][cdc-connector][mongodb] Add `op_type` metadata column

2

Add `op_type` metadata column for mongodb source connector

qg-lin

[FLINK-35670][cdc-connector][postgres]Flink cdc pipeline support postgres source

10

Fork from : https://github.com/apache/flink-cdc/pull/3442 1. Add pipeline IT Case 2. fixed db.sch*.talbe*, db must same and unique

Mrart

[FLINK-37630] Support flink cdc pipeline Yarn session mode

3

Support flink cdc pipeline Yarn session mode

Mrart

[FLINK-36805][cdc-common] Add ConfigShade interface to support encryption of sensitive configuration items and provide a base64 encoding implementation

2

## Introduction When Flink CDC uses pipeline to submit jobs, we need to set configuration items in plaintext in the definition file, including sensitive configurations such as passwords for connecting...

Jzjsnow

close [FLINK-37958](https://issues.apache.org/jira/browse/FLINK-37958)

beryllw