We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ae771d7 commit 18584b1Copy full SHA for 18584b1
storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java
@@ -556,15 +556,14 @@ private boolean cleanFilthiestLog() throws LogCleaningException {
556
} else {
557
// there's a log, clean it
558
this.lastPreCleanStats = preCleanStats;
559
- LogToClean cleanable = null;
+ LogToClean cleanable = ltc.get();
560
try {
561
- cleanable = ltc.get();
562
cleanLog(cleanable);
563
cleaned = true;
564
} catch (ThreadShutdownException e) {
565
throw e;
566
} catch (Exception e) {
567
- throw new LogCleaningException(cleanable != null ? cleanable.log() : null, e.getMessage(), e);
+ throw new LogCleaningException(cleanable.log(), e.getMessage(), e);
568
}
569
570
0 commit comments