From eb06a2753a5aa80241750eccee4f5104b3d05b22 Mon Sep 17 00:00:00 2001
From: Gunnar Morling <gunnar.morling@googlemail.com>
Date: Wed, 29 Apr 2020 09:23:14 +0200
Subject: [PATCH] DBZ-1985 More meaningful exception in case of non-existent
 commit log dir

---
 .../java/io/debezium/connector/cassandra/CommitLogUtil.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CommitLogUtil.java b/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CommitLogUtil.java
index cbfbfcade..b17e6b6d6 100644
--- a/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CommitLogUtil.java
+++ b/debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CommitLogUtil.java
@@ -69,6 +69,10 @@ public static void deleteCommitLog(File file) {
      * If the directory does not contain any commit logs, an empty array is returned.
      */
     public static File[] getCommitLogs(File directory) {
+        if (!directory.isDirectory()) {
+            throw new IllegalArgumentException("Given directory does not exist: " + directory);
+        }
+
         return directory.listFiles(f -> f.isFile() && FILENAME_REGEX_PATTERN.matcher(f.getName()).matches());
     }