lzshlzsh

Results 11 comments of lzshlzsh

[FLINK-29306][shell] Fix the error detection of multiple flink-dist-*.jar for config.sh

@flinkbot run azure

[FLINK-29306][shell] Fix the error detection of multiple flink-dist-*.jar for config.sh

> Good spot. I've tested the change locally, by calling the function changes manually, and it appears to be working well now. > > I have added my approval, however...

[mysql]fix duplicate split request for newly added table

+1, the fix solved our online problem

[mysql]fix duplicate split request for newly added table

Would you explain how to reproduce the bug more detailed ? I have tried tens times according to #1149 , but could not reproduce. You say: "Which lead to two...

[postgres] Remove unnecessary schema fresh to improve performance.

@loserwang1024 @ruanhang1993 @leonardBang @minchowang Would you help to have a review when you have time ?

[postgres] Remove unnecessary schema fresh to improve performance.

Add another schema optimization to optimize the time consumption of schema acquisition in multi table and whole database synchronization scenarios. When the `getTableSchema(TableId tableId)` function retrieves the schema of a...

[mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient

@leonardBang @kylemeow @minchowang Would you help to look at this problem.

[mysql-cdc] Fix the hung up of snapshot phase when reuse binaryLogClient

We just encountered this problem online. The snapshot stage is stuck, and the problem is solved after this repair. @minchowang

[FLINK-35291] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

@ruanhang1993 Would you help to have a look at this?

[FLINK-35291] Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

> @lzshlzsh What's the performance gain (or throughput improve) with this patch? Sorry for the late reply. According to my testing, there is approximately a 40% performance improvement (3.5w/s ->5w/s)....