North Lin

icon location 为爱发电

Results 11 comments of North Lin

[FLINK-34865][pipeline-connector]support sync table and column comments

resolve some problems from PR https://github.com/apache/flink-cdc/pull/3039, thanks for @lvyanquan and @dufeng1010 and @yuxiqian

[FLINK-34865][pipeline-connector]support sync table and column comments

> fix paimon ![image](https://private-user-images.githubusercontent.com/1145830/356470073-c2e9ceef-80f3-433e-bddf-165d7390a44b.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MjMxODI1NjcsIm5iZiI6MTcyMzE4MjI2NywicGF0aCI6Ii8xMTQ1ODMwLzM1NjQ3MDA3My1jMmU5Y2VlZi04MGYzLTQzM2UtYmRkZi0xNjVkNzM5MGE0NGIucG5nP1gtQW16LUFsZ29yaXRobT1BV1M0LUhNQUMtU0hBMjU2JlgtQW16LUNyZWRlbnRpYWw9QUtJQVZDT0RZTFNBNTNQUUs0WkElMkYyMDI0MDgwOSUyRnVzLWVhc3QtMSUyRnMzJTJGYXdzNF9yZXF1ZXN0JlgtQW16LURhdGU9MjAyNDA4MDlUMDU0NDI3WiZYLUFtei1FeHBpcmVzPTMwMCZYLUFtei1TaWduYXR1cmU9MTdmMzc1ZjgyYjdhOGZiOTY2MTRmMDAyMjhiNzRmMWYyOGFlZjlkY2I3N2VmY2JiMTIxMzdlMDYyMGJhMTU5NiZYLUFtei1TaWduZWRIZWFkZXJzPWhvc3QmYWN0b3JfaWQ9MCZrZXlfaWQ9MCZyZXBvX2lkPTAifQ.NqsKRTql94WvQt6tNdc682WUZhWOT8QyJIfINrKWM-c) @melin thanks

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

@Jiabao-Sun @yuxiqian PTAL

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

Since DeduplicateFunctionHelper#processLastRowOnChangelog returns the row before deletion, the `delete` type is temporarily missing.

[FLINK-36375][cdc-runtime] fix missing default value in AddColumnEvent/RenameColunEvent

@lvyanquan @yuxiqian PTAL

[FLINK-36375][cdc-runtime] fix missing default value in AddColumnEvent/RenameColunEvent

> Thanks for @qg-lin's contribution! Seems lenientized `RenameColumnEvent` is also prone to this issue. Would you like to fix this in this PR? my pleasure

[FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector.

> @qg-lin Thanks for your PR. Please rebase the master branch and resolve the conflicts. Then let's run the CI. > > If you need helps, please be free to...

[FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector.

> @qg-lin Please rebase the master branch and let's pass the CI. done

[FLINK-35143][cdc-connector][mysql] Expose newly added tables capture in mysql pipeline connector.

> @qg-lin It seems that some tests failed. Please take a look at them. Thanks. @ruanhang1993 Done, please trigger again.

[FLINK-35544][minor][docs] Add deployment documentations for Kubernetes Operator.

> Thanks for the contributiion @qg-lin , could you create a FLINK JIRA and link it? it will be great if you can add some description for this PR Done!