This is an automated email from the ASF dual-hosted git repository. hequn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0d112f5 [FLINK-14300][runtime] Cleanup operator threads in case StreamTask fails to allocate operatorChain (#9857) add df44cce [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the source code No new revisions were added by this update. Summary of changes: .gitignore | 1 - flink-python/README.md | 13 + flink-python/pom.xml | 20 - .../pyflink/fn_execution/flink_fn_execution_pb2.py | 509 +++++++++++++++++++++ .../tests/test_flink_fn_execution_pb2_synced.py | 43 ++ flink-python/pyflink/gen_protos.py | 70 ++- .../pyflink/proto/flink-fn-execution.proto | 2 + flink-python/pyflink/testing/test_case_utils.py | 3 - flink-python/setup.py | 36 +- pom.xml | 1 - 10 files changed, 623 insertions(+), 75 deletions(-) create mode 100644 flink-python/pyflink/fn_execution/flink_fn_execution_pb2.py create mode 100644 flink-python/pyflink/fn_execution/tests/test_flink_fn_execution_pb2_synced.py