Skip to content

Commit 68a213c

Browse files
author
Vincent Royer
committed
Check CL file exists in producer-v3
1 parent 3b66b66 commit 68a213c

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

producer-v3/src/main/java/com/datastax/cassandra/cdc/producer/CommitLogReaderProcessor.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,10 @@ public void process() throws InterruptedException {
6262
File file = null;
6363
while (true) {
6464
file = this.commitLogQueue.take();
65+
if (!file.exists()) {
66+
log.debug("file={} does not exist any more, ignoring", file.getName());
67+
continue;
68+
}
6569
long seg = CommitLogUtil.extractTimestamp(file.getName());
6670

6771
// ignore file before the last write offset

0 commit comments

Comments
 (0)