This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from dfd785c2b3a [FLINK-38974][runtime] Handle jobs in running applications
during HA recovery
add 5af78e24cc0 [FLINK-39173][runtime] Support application-level blob
storage
No new revisions were added by this update.
Summary of changes:
.../handlers/JarRunApplicationHandler.java | 61 +++-
.../webmonitor/handlers/utils/JarHandlerUtils.java | 4 +
.../flink/runtime/blob/AbstractBlobCache.java | 89 +++++
.../org/apache/flink/runtime/blob/BlobClient.java | 190 ++++++++++
.../flink/runtime/blob/BlobOutputStream.java | 33 +-
.../org/apache/flink/runtime/blob/BlobServer.java | 342 +++++++++++++++++-
.../flink/runtime/blob/BlobServerConnection.java | 95 ++++-
.../flink/runtime/blob/BlobServerProtocol.java | 3 +
.../org/apache/flink/runtime/blob/BlobStore.java | 35 ++
.../org/apache/flink/runtime/blob/BlobUtils.java | 197 ++++++++++-
.../org/apache/flink/runtime/blob/BlobView.java | 12 +
.../flink/runtime/blob/FileSystemBlobStore.java | 31 +-
.../flink/runtime/blob/PermanentBlobCache.java | 20 ++
.../flink/runtime/blob/PermanentBlobService.java | 15 +
.../flink/runtime/blob/TransientBlobCache.java | 4 +-
.../apache/flink/runtime/blob/VoidBlobStore.java | 23 ++
.../apache/flink/runtime/client/ClientUtils.java | 22 ++
...a => GloballyCleanableApplicationResource.java} | 19 +-
.../runner/SessionDispatcherLeaderProcess.java | 2 +
.../flink/runtime/blob/BlobClientSslTest.java | 62 ++++
.../apache/flink/runtime/blob/BlobClientTest.java | 170 ++++++++-
.../flink/runtime/blob/BlobServerCleanupTest.java | 128 +++++++
.../flink/runtime/blob/BlobServerDeleteTest.java | 50 +++
.../flink/runtime/blob/BlobServerGetTest.java | 388 +++++++++++++++++++++
.../flink/runtime/blob/BlobServerPutTest.java | 371 ++++++++++++++++++++
.../runtime/blob/BlobUtilsNonWritableTest.java | 16 +-
.../apache/flink/runtime/blob/BlobUtilsTest.java | 90 +++++
.../flink/runtime/blob/TestingBlobHelpers.java | 78 +++++
.../flink/runtime/blob/TestingBlobStore.java | 49 ++-
.../runtime/blob/TestingBlobStoreBuilder.java | 55 ++-
.../flink/runtime/blob/TestingBlobUtils.java | 33 ++
.../flink/runtime/client/ClientUtilsTest.java | 21 ++
.../highavailability/AbstractHaServicesTest.java | 23 ++
33 files changed, 2677 insertions(+), 54 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/{GloballyCleanableResource.java
=> GloballyCleanableApplicationResource.java} (68%)
