From 1d19be629ec14ee2a6bed28aa33a8c0bd3b68329 Mon Sep 17 00:00:00 2001 From: beliefer Date: Mon, 24 Mar 2025 12:18:36 +0800 Subject: [PATCH] [hotfix] Short circuit judgment for create blob storage dir --- .../src/main/java/org/apache/flink/runtime/blob/BlobUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; } }