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/11/19 09:40:09 UTC
[flink] branch master updated (99551e8 -> df9b757)
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 99551e8 [hotfix] Add general options to cli options in SQL cli LocalExecutor
add df9b757 [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.
No new revisions were added by this update.
Summary of changes:
flink-dist/src/main/assemblies/bin.xml | 3 +
flink-dist/src/main/assemblies/opt.xml | 7 --
flink-python/bin/pyflink-shell.sh | 18 +++--
flink-python/bin/pyflink-udf-runner.sh | 65 +++++------------
flink-python/pom.xml | 19 +++++
.../fn_execution/tests/test_process_mode_boot.py | 6 +-
flink-python/pyflink/shell.py | 20 ++++++
.../apache/flink/client/python/PythonDriver.java | 4 +-
...thonEnvUtils.java => PythonDriverEnvUtils.java} | 75 ++++---------------
.../client/python/PythonResourceExtractor.java | 37 ++++++----
.../flink/python/AbstractPythonFunctionRunner.java | 84 ++++++++++++++++++++--
.../org/apache/flink/python/util/ResourceUtil.java | 77 ++++++++++++++++++++
...tilsTest.java => PythonDriverEnvUtilsTest.java} | 38 ++++++++--
.../apache/flink/python/util/ResourceUtilTest.java | 82 +++++++++++++++++++++
14 files changed, 385 insertions(+), 150 deletions(-)
rename flink-python/src/main/java/org/apache/flink/client/python/{PythonEnvUtils.java => PythonDriverEnvUtils.java} (70%)
copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/rules/LookupCallByNameRule.java => flink-python/src/main/java/org/apache/flink/client/python/PythonResourceExtractor.java (51%)
create mode 100644 flink-python/src/main/java/org/apache/flink/python/util/ResourceUtil.java
rename flink-python/src/test/java/org/apache/flink/client/python/{PythonEnvUtilsTest.java => PythonDriverEnvUtilsTest.java} (73%)
create mode 100644 flink-python/src/test/java/org/apache/flink/python/util/ResourceUtilTest.java