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 22334ff [FLINK-17306] Call open of SerializationSchema in RMQ sink
add 7a28dbe [FLINK-12717][python] Add windows support for PyFlink (#11960)
No new revisions were added by this update.
Summary of changes:
.../pyflink/datastream/tests/test_state_backend.py | 32 ++--
flink-python/pyflink/find_flink_home.py | 11 +-
.../fn_execution/tests/test_process_mode_boot.py | 20 +-
flink-python/pyflink/gen_protos.py | 6 +-
flink-python/pyflink/java_gateway.py | 38 ++--
...llback_server.py => pyflink_callback_server.py} | 6 +-
flink-python/pyflink/pyflink_gateway_server.py | 210 +++++++++++++++++++++
.../pyflink/table/tests/test_dependency.py | 5 +-
.../pyflink/table/tests/test_pandas_udf.py | 10 +-
flink-python/pyflink/table/tests/test_types.py | 7 +
.../apache/flink/client/python/PythonEnvUtils.java | 3 +-
.../flink/client/python/PythonFunctionFactory.java | 2 +-
.../flink/client/python/PythonGatewayServer.java | 39 +++-
.../env/ProcessPythonEnvironmentManager.java | 44 ++++-
.../org/apache/flink/python/util/ResourceUtil.java | 14 +-
.../src/main/resources/pyflink-udf-runner.bat | 54 ++++++
.../src/main/resources/pyflink-udf-runner.sh | 2 +-
17 files changed, 430 insertions(+), 73 deletions(-)
rename flink-python/pyflink/{python_callback_server.py =>
pyflink_callback_server.py} (89%)
create mode 100644 flink-python/pyflink/pyflink_gateway_server.py
create mode 100644 flink-python/src/main/resources/pyflink-udf-runner.bat
