diff --git a/src/java/org/apache/cassandra/db/commitlog/CommitLogArchiver.java b/src/java/org/apache/cassandra/db/commitlog/CommitLogArchiver.java index d7eee3ae74..1b1a1e0935 100644 --- a/src/java/org/apache/cassandra/db/commitlog/CommitLogArchiver.java +++ b/src/java/org/apache/cassandra/db/commitlog/CommitLogArchiver.java @@ -82,14 +82,17 @@ public class CommitLogArchiver archiveCommand = commitlog_commands.getProperty("archive_command"); restoreCommand = commitlog_commands.getProperty("restore_command"); restoreDirectories = commitlog_commands.getProperty("restore_directories"); - for (String dir : restoreDirectories.split(DELIMITER)) + if (restoreDirectories != null && !restoreDirectories.isEmpty()) { - File directory = new File(dir); - if (!directory.exists()) + for (String dir : restoreDirectories.split(DELIMITER)) { - if (!directory.mkdir()) + File directory = new File(dir); + if (!directory.exists()) { - throw new RuntimeException("Unable to create directory " + dir); + if (!directory.mkdir()) + { + throw new RuntimeException("Unable to create directory: " + dir); + } } } }