diff --git a/fluss-server/src/main/java/org/apache/fluss/server/log/LogManager.java b/fluss-server/src/main/java/org/apache/fluss/server/log/LogManager.java index c35ed209b3..048a2f5424 100644 --- a/fluss-server/src/main/java/org/apache/fluss/server/log/LogManager.java +++ b/fluss-server/src/main/java/org/apache/fluss/server/log/LogManager.java @@ -183,7 +183,7 @@ private void loadLogs() { } else if (isCleanShutdown) { LOG.info("Skipping some recovery log process since clean shutdown file was found"); } else { - LOG.info("Recovering all local logs since no clean shutdown file was not found"); + LOG.info("Recovering all local logs since no clean shutdown file was found"); } final Map finalRecoveryPoints = recoveryPoints; @@ -200,7 +200,7 @@ private void loadLogs() { loadLogsCompletedFlag = true; LOG.info( - "log loader complete. Total success loaded log count is {}, Take {} ms", + "Log loader complete. Total success loaded log count is {}, Take {} ms", successLoadCount, System.currentTimeMillis() - startTime); } catch (Throwable e) {