You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/11/09 11:28:01 UTC
[flink] branch master updated (1806a37 -> c1e9aef)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1806a37 [FLINK-14673][hive] Shouldn't expect HMS client to throw NoSuchObjectException for non-existing function
add c1e9aef [FLINK-14465] Let StandaloneJobClusterEntryPoint use the user code class loader
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/client/cli/CliFrontend.java | 9 +-
.../flink/client/program/PackagedProgram.java | 255 +++++++++------------
.../flink/client/program/PackagedProgramUtils.java | 8 +
.../client/cli/CliFrontendPackageProgramTest.java | 1 +
.../apache/flink/client/program/ClientTest.java | 15 +-
.../client/program/ExecutionPlanCreationTest.java | 5 +-
.../flink/client/program/PackagedProgramTest.java | 17 +-
flink-container/docker/Dockerfile | 3 +-
flink-container/docker/docker-entrypoint.sh | 2 +-
flink-container/pom.xml | 60 +++++
.../entrypoint/ClassPathJobGraphRetriever.java | 149 ++++++++++--
.../entrypoint/StandaloneJobClusterEntryPoint.java | 10 +-
...est-assembly-test-user-classloader-job-jar.xml} | 4 +-
...assembly-test-user-classloader-job-lib-jar.xml} | 4 +-
.../entrypoint/ClassPathJobGraphRetrieverTest.java | 181 ++++++++++++---
.../container/entrypoint/testjar/TestJobInfo.java | 25 +-
.../TestUserClassLoaderJob.java} | 30 +--
.../testjar/TestUserClassLoaderJobLib.java | 14 +-
.../flink/configuration/ConfigConstants.java | 3 +
.../main/java/org/apache/flink/util/FileUtils.java | 28 +++
.../streaming/examples/wordcount/WordCount.java | 1 -
.../formats/avro/AvroExternalJarProgramITCase.java | 5 +-
.../handlers/EntryClassQueryParameter.java | 4 +-
.../webmonitor/handlers/JarListHandler.java | 2 +-
.../handlers/ProgramArgQueryParameter.java | 4 +-
.../handlers/ProgramArgsQueryParameter.java | 4 +-
.../webmonitor/handlers/utils/JarHandlerUtils.java | 9 +-
.../runtime/entrypoint/ClusterEntrypoint.java | 2 +-
.../flink/runtime/util/ClusterEntrypointUtils.java | 62 +++++
.../flink/test/classloading/ClassLoaderITCase.java | 58 +++--
.../apache/flink/yarn/YarnConfigurationITCase.java | 2 +-
31 files changed, 662 insertions(+), 314 deletions(-)
copy flink-container/src/test/assembly/{test-assembly.xml => test-assembly-test-user-classloader-job-jar.xml} (88%)
copy flink-container/src/test/assembly/{test-assembly.xml => test-assembly-test-user-classloader-job-lib-jar.xml} (88%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUpload.java => flink-container/src/test/java/org/apache/flink/container/entrypoint/testjar/TestJobInfo.java (59%)
copy flink-container/src/test/java/org/apache/flink/container/entrypoint/{TestJob.java => testjar/TestUserClassLoaderJob.java} (61%)
copy flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureFSFactory.java => flink-container/src/test/java/org/apache/flink/container/entrypoint/testjar/TestUserClassLoaderJobLib.java (78%)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterEntrypointUtils.java