You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/10 14:16:17 UTC
[flink] 02/03: [hotfix][runtime] Adds check for consistency to avoid NullPointerException
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 <ma...@ververica.com>
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())) {