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 95f3f7d [hotfix] Remove unused
TaskExecutorLocalStateStoresManagerTest.TOTAL_FLINK_MEMORY_MB
add 4df667f [FLINK-25404] Let blob.storage.directory default to
<WORKING_DIR>/blobs
add d31471e [FLINK-25404] Introduce borrowed and owned storage directory
to BlobServer/Cache for better clean up
No new revisions were added by this update.
Summary of changes:
.../generated/blob_server_configuration.html | 2 +-
.../flink/configuration/BlobServerOptions.java | 3 +-
.../main/java/org/apache/flink/util/Reference.java | 41 ++++++---
.../java/org/apache/flink/util/ReferenceTest.java | 58 ++++++++++++
.../java/org/apache/flink/hdfstests/HDFSTest.java | 10 ++-
.../flink/runtime/blob/AbstractBlobCache.java | 20 +++--
.../flink/runtime/blob/BlobCacheService.java | 19 +++-
.../org/apache/flink/runtime/blob/BlobServer.java | 46 ++++++----
.../org/apache/flink/runtime/blob/BlobUtils.java | 100 +++++++++++++++------
.../flink/runtime/blob/PermanentBlobCache.java | 46 +++++++---
.../flink/runtime/blob/TransientBlobCache.java | 23 +++--
.../runtime/entrypoint/ClusterEntrypoint.java | 40 +++++----
.../flink/runtime/entrypoint/WorkingDirectory.java | 8 ++
.../flink/runtime/minicluster/MiniCluster.java | 11 ++-
.../runtime/taskexecutor/TaskManagerRunner.java | 9 +-
.../flink/runtime/blob/BlobCacheCleanupTest.java | 38 ++++----
.../runtime/blob/BlobCacheCorruptionTest.java | 24 +++--
.../flink/runtime/blob/BlobCacheDeleteTest.java | 28 +++---
.../flink/runtime/blob/BlobCacheGetTest.java | 42 ++++-----
.../flink/runtime/blob/BlobCachePutTest.java | 66 ++++++--------
.../flink/runtime/blob/BlobCacheRecoveryTest.java | 23 ++---
.../flink/runtime/blob/BlobCacheRetriesTest.java | 72 ++++++---------
.../flink/runtime/blob/BlobCacheSuccessTest.java | 7 +-
.../flink/runtime/blob/BlobClientSslTest.java | 12 +--
.../apache/flink/runtime/blob/BlobClientTest.java | 10 +--
.../flink/runtime/blob/BlobServerCleanupTest.java | 5 +-
.../runtime/blob/BlobServerCorruptionTest.java | 18 ++--
.../flink/runtime/blob/BlobServerDeleteTest.java | 27 +++---
.../flink/runtime/blob/BlobServerGetTest.java | 28 +++---
.../flink/runtime/blob/BlobServerPutTest.java | 41 ++++-----
.../flink/runtime/blob/BlobServerRangeTest.java | 14 ++-
.../flink/runtime/blob/BlobServerRecoveryTest.java | 22 ++---
.../flink/runtime/blob/BlobServerSSLTest.java | 10 ++-
.../apache/flink/runtime/blob/BlobServerTest.java | 70 ---------------
.../runtime/blob/BlobUtilsNonWritableTest.java | 2 +-
.../apache/flink/runtime/blob/BlobUtilsTest.java | 68 +++-----------
.../blob/PermanentBlobCacheSizeLimitTest.java | 27 +++---
.../runtime/blob/TestingFailingBlobServer.java | 14 ++-
.../flink/runtime/client/ClientUtilsTest.java | 5 +-
.../runtime/dispatcher/AbstractDispatcherTest.java | 7 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 13 +--
.../runtime/dispatcher/MiniDispatcherTest.java | 7 +-
.../ZooKeeperDefaultDispatcherRunnerTest.java | 5 +-
.../librarycache/BlobLibraryCacheManagerTest.java | 45 ++++++----
.../BlobLibraryCacheRecoveryITCase.java | 18 ++--
...tExecutionGraphDeploymentWithBlobCacheTest.java | 6 +-
...ExecutionGraphDeploymentWithBlobServerTest.java | 8 +-
...hDeploymentWithSmallBlobCacheSizeLimitTest.java | 8 +-
.../jobmaster/JobManagerSharedServicesTest.java | 6 +-
.../rest/handler/job/JobSubmitHandlerTest.java | 6 +-
.../AbstractTaskManagerFileHandlerTest.java | 6 +-
.../flink/runtime/util/BlobServerExtension.java | 5 +-
.../flink/runtime/util/BlobServerResource.java | 5 +-
53 files changed, 666 insertions(+), 588 deletions(-)
copy
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowedValue.java
=> flink-core/src/main/java/org/apache/flink/util/Reference.java (52%)
create mode 100644
flink-core/src/test/java/org/apache/flink/util/ReferenceTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobServerTest.java
