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(-)
