@FunctionalInterface public interface LocallyCleanableResource
LocallyCleanableResourceis supposed to be implemented by any class that provides artifacts for a given job that need to be cleaned up after the job reached a local terminal state. Local cleanups that needs to be triggered for a global terminal state as well, need to be implemented using the
DispatcherResourceCleanerFactory provides a workaround to trigger some
LocallyCleanableResources as globally cleanable. FLINK-26175 is created to cover a refactoring
and straighten things out.
CompletableFuture<Void> localCleanupAsync(JobID jobId, Executor cleanupExecutor)
localCleanupAsyncis expected to be called from the main thread. Heavy IO tasks should be outsourced into the passed
cleanupExecutor. Thread-safety must be ensured.
JobIDof the job for which the local data should be cleaned up.
cleanupExecutor- The fallback executor for IO-heavy operations.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.