diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java index 75fb67b7391dd..c108d1259e93c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java @@ -161,7 +161,7 @@ static Reference createBlobStorageDirectory( if (fallbackStorageDirectory != null) { baseDir = fallbackStorageDirectory.deref(); - if (baseDir.mkdirs() || baseDir.exists()) { + if (baseDir.exists() || baseDir.mkdirs()) { return fallbackStorageDirectory; } }