Re: [PR] [Mysql Pipline] Support mysql pipline rate limit [flink-cdc]

2024-09-13 Thread via GitHub
gaoyan1998 closed pull request #3547: [Mysql Pipline] Support mysql pipline rate limit URL: https://github.com/apache/flink-cdc/pull/3547 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [Mysql Pipline] Support mysql pipline rate limit [flink-cdc]

2024-09-13 Thread via GitHub
gaoyan1998 commented on PR #3547: URL: https://github.com/apache/flink-cdc/pull/3547#issuecomment-2348856963 @yuxiqian @leonardBang Thanks for guidance, the new pr is #3607. I will closed this pr. -- This is an automated message from the Apache Git Service. To respond to the message, pl

Re: [PR] [Mysql Pipline] Support mysql pipline rate limit [flink-cdc]

2024-08-21 Thread via GitHub
yuxiqian commented on PR #3547: URL: https://github.com/apache/flink-cdc/pull/3547#issuecomment-2303600839 Will [FLIP-238](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217385972) be helpful when implementing rate limited source? -- This is an automated message from th

Re: [PR] [Mysql Pipline] Support mysql pipline rate limit [flink-cdc]

2024-08-21 Thread via GitHub
gaoyan1998 commented on PR #3547: URL: https://github.com/apache/flink-cdc/pull/3547#issuecomment-2303594608 > Thanks @gaoyan1998 for the contribution, FLIP 27 Source API also has a basic rate limiting design, Would you consider develop base on that one? yes i can do it. Can you give

Re: [PR] [Mysql Pipline] Support mysql pipline rate limit [flink-cdc]

2024-08-19 Thread via GitHub
leonardBang commented on PR #3547: URL: https://github.com/apache/flink-cdc/pull/3547#issuecomment-2296584623 Thanks @gaoyan1998 for the contribution, FLIP 27 Source API also has a basic rate limiting design, Would you consider develop base on that one? -- This is an automated message fr

[PR] [Mysql Pipline] Support mysql pipline rate limit [flink-cdc]

2024-08-17 Thread via GitHub
gaoyan1998 opened a new pull request, #3547: URL: https://github.com/apache/flink-cdc/pull/3547 This PR Support speed rate, Prevent too much data in the initial stage from causing pressure downstream usageļ¼š ```yaml source: type: mysql sink: