@FunctionalInterface public interface LocallyCleanableResource
LocallyCleanableResource is 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)
localCleanupAsync is expected to be called from the main thread. Heavy IO tasks
should be outsourced into the passed
cleanupExecutor. Thread-safety must be ensured.
jobId - The
JobID of the job for which the local data should be cleaned up.
cleanupExecutor - The fallback executor for IO-heavy operations.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.