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

Posted to commits@flink.apache.org by he...@apache.org on 2019/10/09 15:29:08 UTC

[flink] branch master updated (0d112f5 -> df44cce)

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