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