[flink] branch master updated (f503fef -> d62be2e)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from f503fef  [FLINK-25053][docs] Document how to use the usrlib to load code in the user code class loader
     add 689b01e  [hotfix] Adds @Nullable annotation
     add 1827602  [hotfix] Introduces public constants for file extension
     add 74d7369  [hotfix] Adds missing assert to make finally use of the local variable
     add 23db91f  [FLINK-26015] Adds TestContainerExtension and MinioTestContainer
     add 0d0a3ac  [FLINK-26015] Fixes FileSystemJobResultStore
     add d62be2e  [FLINK-26015] Adds testcase covering a basic job execution in HA with object store as a backend storage

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink/core/fs/FileSystem.java  |   2 +-
 flink-filesystems/flink-s3-fs-base/pom.xml         |  42 ++++++
 .../fs/s3/common/HAJobRunOnMinioS3StoreITCase.java | 131 +++++++++++++++++++
 .../flink/fs/s3/common/MinioTestContainer.java     | 143 +++++++++++++++++++++
 .../flink/fs/s3/common/MinioTestContainerTest.java | 118 +++++++++++++++++
 flink-filesystems/flink-s3-fs-hadoop/pom.xml       |  38 ++++++
 .../HAJobRunOnHadoopS3FileSystemITCase.java}       |  11 +-
 flink-filesystems/flink-s3-fs-presto/pom.xml       |  38 ++++++
 .../HAJobRunOnPrestoS3FileSystemITCase.java}       |  11 +-
 .../highavailability/FileSystemJobResultStore.java |  35 +++--
 .../highavailability/AbstractHAJobRunITCase.java   | 125 ++++++++++++++++++
 .../FileSystemJobResultStoreTestInternal.java      |  45 ++++++-
 .../flink-test-utils-junit/pom.xml                 |   6 +
 .../core/testutils/TestContainerExtension.java     |  72 +++++++++++
 .../org/apache/flink/util/DockerImageVersions.java |   2 +
 15 files changed, 787 insertions(+), 32 deletions(-)
 create mode 100644 flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/HAJobRunOnMinioS3StoreITCase.java
 create mode 100644 flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java
 create mode 100644 flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainerTest.java
 copy flink-filesystems/flink-s3-fs-hadoop/src/{main/java/org/apache/flink/fs/s3hadoop/S3AFileSystemFactory.java => test/java/org/apache/flink/fs/s3hadoop/HAJobRunOnHadoopS3FileSystemITCase.java} (77%)
 copy flink-filesystems/flink-s3-fs-presto/src/{main/java/org/apache/flink/fs/s3presto/S3PFileSystemFactory.java => test/java/org/apache/flink/fs/s3presto/HAJobRunOnPrestoS3FileSystemITCase.java} (77%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHAJobRunITCase.java
 create mode 100644 flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/TestContainerExtension.java