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 60b0745 [FLINK-20678] Let JobManagerRunnerImpl fail if the
JobMasterService fails unexpectedly
add 6ed081f [FLINK-20640][python] Use cython to optimize the performance
of Python UDAF
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/fn_execution/aggregate.py | 571 +--------------------
.../pyflink/fn_execution/aggregate_fast.pxd | 95 ++++
.../{aggregate.py => aggregate_fast.pyx} | 537 ++++++++-----------
.../{aggregate.py => aggregate_slow.py} | 161 +-----
.../pyflink/fn_execution/coder_impl_fast.pxd | 4 +-
.../pyflink/fn_execution/coder_impl_fast.pyx | 21 +-
flink-python/pyflink/fn_execution/operations.py | 14 +-
flink-python/setup.py | 8 +
8 files changed, 340 insertions(+), 1071 deletions(-)
create mode 100644 flink-python/pyflink/fn_execution/aggregate_fast.pxd
copy flink-python/pyflink/fn_execution/{aggregate.py => aggregate_fast.pyx}
(54%)
copy flink-python/pyflink/fn_execution/{aggregate.py => aggregate_slow.py}
(80%)
