This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from c4b18dbb24 [Feature] Add `init` and `restoreCommit` method in
`SinkAggregatedCommitter` (#5598)
add d881dd6258 [Feature][Flink] Support flow control in Flink (#5509)
No new revisions were added by this update.
Summary of changes:
docs/en/concept/speed-limit.md | 1 +
.../starter/flowcontrol/FlowControlStrategy.java | 42 ++++++++++++++++++++++
.../starter/flink/execution/FlinkExecution.java | 3 +-
.../flink/execution/SourceExecuteProcessor.java | 13 ++++---
.../src/test/resources/mysqlcdc_to_mysql.conf | 2 ++
.../engine/server/task/SourceSeaTunnelTask.java | 40 ++-------------------
.../seatunnel-translation-flink-common/pom.xml | 5 +++
.../flink/source/BaseSeaTunnelSourceFunction.java | 23 ++++++++++--
.../translation/flink/source/RowCollector.java | 20 +++++++++--
.../flink/source/SeaTunnelCoordinatedSource.java | 7 ++--
.../flink/source/SeaTunnelParallelSource.java | 6 ++--
11 files changed, 109 insertions(+), 53 deletions(-)
