You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2020/05/15 18:10:10 UTC
[flink] branch master updated (cd1f858 -> 6d97318)
This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cd1f858 [FLINK-17218][tests] Adding recoverable failures and correctness checks to UnalignedCheckpointITCase.
add 04bcc25 [FLINK-17632][yarn] Always build the packaged program in the cluster for application mode
add 681b211 [FLINK-17632][yarn] Support to specify a remote path for job jar
add 7bea158 [FLINK-17632][yarn] Move some variables as member of YarnApplicationFileUploader to make it more self-contained
add 8c52ea0 [minor] Refactoring the ClassPathPackagedProgramRetriever creation
add f3681d2 [hotfix][yarn] Add validation in YarnClusterDescriptor when parsing provided lib directories
add 6d97318 [FLINK-17729][yarn] Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/client/cli/CliFrontend.java | 28 +--
.../StandaloneApplicationClusterEntryPoint.java | 4 +-
.../KubernetesApplicationClusterEntrypoint.java | 4 +-
.../apache/flink/yarn/YARNApplicationITCase.java | 123 +++++++++++
.../java/org/apache/flink/yarn/YARNITCase.java | 34 ++--
.../java/org/apache/flink/yarn/YarnTestBase.java | 7 +-
.../src/main/java/org/apache/flink/yarn/Utils.java | 5 +
.../flink/yarn/YarnApplicationFileUploader.java | 224 ++++++++++++++-------
.../apache/flink/yarn/YarnClusterDescriptor.java | 148 +++++++-------
.../flink/yarn/YarnLocalResourceDescriptor.java | 16 ++
.../YarnApplicationClusterEntryPoint.java | 19 +-
.../yarn/YarnApplicationFileUploaderTest.java | 7 +-
.../flink/yarn/YarnClusterDescriptorTest.java | 41 +++-
.../org/apache/flink/yarn/YarnFileStageTest.java | 67 +++---
.../flink/yarn/YarnFileStageTestS3ITCase.java | 4 +-
15 files changed, 515 insertions(+), 216 deletions(-)
create mode 100644 flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNApplicationITCase.java