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 fd273a5a3c3 [FLINK-38609][table] Regenerate plans in deterministic
manner
add 8688dce69d8 [FLINK-38615][python] Optimize AsyncFunction to remove
ResultFuture to make it more Pythonic (#27184)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/__init__.py | 3 +-
flink-python/pyflink/datastream/functions.py | 49 ++---------
.../datastream/tests/test_async_function.py | 94 +++++++++++-----------
.../datastream/process/async_function/operation.py | 78 ++++++++++++------
.../datastream/process/async_function/queue.py | 30 ++++++-
5 files changed, 137 insertions(+), 117 deletions(-)
