This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6ea1782246c0099c8b00067558739850f31e5a68 Author: Matthias Pohl <[email protected]> AuthorDate: Fri Mar 4 14:39:35 2022 +0100 [hotfix][runtime] Adds check for consistency to avoid NullPointerException LocalFileSystem.listStatus returns null in case of the path being invalid. --- .../flink/runtime/highavailability/FileSystemJobResultStore.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java b/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java index 363f93e..a7ed3c5 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java @@ -167,8 +167,13 @@ public class FileSystemJobResultStore extends AbstractThreadsafeJobResultStore { @Override public Set<JobResult> getDirtyResultsInternal() throws IOException { + final FileStatus[] statuses = fileSystem.listStatus(this.basePath); + + Preconditions.checkState( + statuses != null, + "The base directory of the JobResultStore isn't accessible. No dirty JobResults can be restored."); + final Set<JobResult> dirtyResults = new HashSet<>(); - FileStatus[] statuses = fileSystem.listStatus(this.basePath); for (FileStatus s : statuses) { if (!s.isDir()) { if (hasValidDirtyJobResultStoreEntryExtension(s.getPath().getName())) {
