diff --git a/common/src/main/java/org/apache/rocketmq/common/UtilAll.java b/common/src/main/java/org/apache/rocketmq/common/UtilAll.java index a42ac3f364..e44f71589c 100644 --- a/common/src/main/java/org/apache/rocketmq/common/UtilAll.java +++ b/common/src/main/java/org/apache/rocketmq/common/UtilAll.java @@ -645,8 +645,10 @@ public class UtilAll { file.delete(); } else if (file.isDirectory()) { File[] files = file.listFiles(); - for (File file1 : files) { - deleteFile(file1); + if (files != null) { + for (File file1 : files) { + deleteFile(file1); + } } file.delete(); }