This is an automated email from the ASF dual-hosted git repository.
yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new cb873e64d [typo] Fix typo in log loading period (#2798)
cb873e64d is described below
commit cb873e64d290e1abf6520a4d00f64f7d09c4e04b
Author: xiaozhou <[email protected]>
AuthorDate: Thu Mar 12 15:49:22 2026 +0800
[typo] Fix typo in log loading period (#2798)
---
.../src/main/java/org/apache/fluss/server/log/LogManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 c35ed209b..048a2f542 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 @@ public final class LogManager extends TabletManagerBase {
} 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<TableBucket, Long> finalRecoveryPoints = recoveryPoints;
@@ -200,7 +200,7 @@ public final class LogManager extends TabletManagerBase {
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) {
