You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by di...@apache.org on 2022/08/09 15:30:25 UTC

[flink] branch master updated (f53dd03fd5f -> 64b430b0738)

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from f53dd03fd5f [FLINK-28487][connectors] Introduce configurable RateLimitingStrategy for AsyncSinkWriter
     add 64b430b0738 [hotfix][python] Refactor thread mode Python runtime to make it more readable

No new revisions were added by this update.

Summary of changes:
 .../fn_execution/datastream/embedded/operations.py | 48 +++--------
 .../datastream/embedded/process_function.py        | 96 +++++++++++-----------
 .../datastream/embedded/side_output_context.py     |  9 +-
 .../datastream/embedded/timerservice_impl.py       | 32 ++++----
 .../datastream/process/timerservice_impl.py        | 11 ++-
 .../fn_execution/table/window_aggregate_fast.pyx   |  4 +-
 .../fn_execution/table/window_aggregate_slow.py    |  4 +-
 7 files changed, 91 insertions(+), 113 deletions(-)