Hongshun Wang comments

Results 61 comments of


                                            Hongshun Wang

[cdc-connector][mysql][hotfix] Avoid mysql source to read data after high_watermark in backfill phase

@leonardBang , @ruanhang1993 , @PatrickRen , @lvyanquan CC

[Bug][mysql] Remove all previous table and add new added table will throw Exception.

@leonardBang , @ruanhang1993 , CC

[fix][cdc-connector][mysql] Fix NoClassDefFoundError when create new table in mysql cdc source

Maybe we should includes the flink-cdc-common moduel in flink-cdc-connector-mysql-cdc module? flink-cdc-connector-mysql-cdc also includes some class of flink-cdc-common, such as annotion. But it also seems that flink-cdc-common is too big for...

[hotfix] [base] Fix the serialization error occurring with table names containing dot

@leonardBang , @ruanhang1993 CC

[postgres] Remove unnecessary schema fresh to improve performance.

@lzshlzsh [FLINK-33465 Make SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving](https://issues.apache.org/jira/browse/FLINK-33465) has already done in Flink. Maybe we can push forward this job again.

[FLINK-35167][cdc-connector] Introduce MaxCompute pipeline DataSink

I am wondering how a commercial database sink like MaxCompute to do e2e test?

[FLINK-35149][cdc-composer] Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

@PatrickRen , CC

[FLINK-35149][cdc-composer] Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

> Could you please add a test case to prevent later code changes to revert this fix? I'd like to, but it seems no pipeline sink which is WithPreWriteTopology but...

[FLINK-35149][cdc-composer] Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

> Could you define your own one in the test itself? Then you have free hands what it does, and does not... Done it.

[FLINK-35149][cdc-composer] Fix DataSinkTranslator#sinkTo ignoring pre-write topology if not TwoPhaseCommittingSink

@PatrickRen , CC, Would you like to help me review this PR?