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

Posted to commits@flink.apache.org by we...@apache.org on 2021/02/07 06:49:49 UTC

[flink] branch master updated (78f4b1f -> 08bb6c1)

This is an automated email from the ASF dual-hosted git repository.

weizhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 78f4b1f  [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch
     add 08bb6c1  [FLINK-21238][python] Support to close PythonFunctionFactory manually

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/java_gateway.py               |   4 +-
 .../apache/flink/client/python/PythonDriver.java   |  11 +-
 .../apache/flink/client/python/PythonEnvUtils.java |  81 ++++---
 .../flink/client/python/PythonFunctionFactory.java | 236 ++++++++++++---------
 .../client/python/PythonFunctionFactoryImpl.java   |  58 +++++
 .../flink/client/python/PythonGatewayServer.java   |   4 +-
 .../client/python/PythonFunctionFactoryTest.java   |   6 +-
 .../client/gateway/local/ExecutionContextTest.java |  42 +++-
 .../flink/table/functions/FunctionService.java     |   4 +-
 .../table/functions/UserDefinedFunctionHelper.java |   2 +-
 .../python/utils/PythonFunctionUtils.java          |  21 +-
 11 files changed, 312 insertions(+), 157 deletions(-)
 create mode 100644 flink-python/src/main/java/org/apache/flink/client/python/PythonFunctionFactoryImpl.java