diff --git a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/metrics/FlinkMetricRegistry.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/metrics/FlinkMetricRegistry.java
index 2420999f8d3..282953f9186 100644
--- a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/metrics/FlinkMetricRegistry.java
+++ b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/metrics/FlinkMetricRegistry.java
@@ -88,7 +88,7 @@ public void register(Metric metric, String metricName, AbstractMetricGroup group
         registerMetric(currentMetricGroup, metric, metricName);
     }
 
-    /** Exposes the metrics of Fluss metics group for flink. */
+    /** Exposes the metrics of Fluss metrics group for flink. */
     public Metric getFlussMetric(String metricName) {
         return metrics.get(metricName);
     }
diff --git a/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshotStore.java b/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshotStore.java
index 7cf3e88db60..f3bb0a81ef7 100644
--- a/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshotStore.java
+++ b/fluss-server/src/main/java/org/apache/fluss/server/kv/snapshot/CompletedSnapshotStore.java
@@ -75,7 +75,7 @@ public class CompletedSnapshotStore {
 
     /**
      * Local copy of the completed snapshots in snapshot store. This is restored from snapshot
-     * handel store when recovering.
+     * handle store when recovering.
      */
     private final ArrayDeque<CompletedSnapshot> completedSnapshots;
 
diff --git a/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java b/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
index cc430a19f91..bc5521e812e 100644
--- a/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
+++ b/fluss-server/src/main/java/org/apache/fluss/server/replica/fetcher/ReplicaFetcherThread.java
@@ -83,7 +83,7 @@ final class ReplicaFetcherThread extends ShutdownableThread {
     private final LeaderEndpoint leader;
     private final int fetchBackOffMs;
 
-    // manually add timout logic in here, todo remove this timeout logic if
+    // manually add timeout logic in here, todo remove this timeout logic if
     // we support global request timeout in #279
     private final int timeoutSeconds;
 
diff --git a/fluss-server/src/test/java/org/apache/fluss/server/ServerTestBase.java b/fluss-server/src/test/java/org/apache/fluss/server/ServerTestBase.java
index c71f0f96c28..71ac5062c3b 100644
--- a/fluss-server/src/test/java/org/apache/fluss/server/ServerTestBase.java
+++ b/fluss-server/src/test/java/org/apache/fluss/server/ServerTestBase.java
@@ -122,7 +122,7 @@ protected static Configuration createConfiguration() {
         configuration.setString(ConfigOptions.ADVERTISED_LISTENERS, "CLIENT://198.168.0.1:100");
         configuration.set(ConfigOptions.REMOTE_DATA_DIR, "/tmp/fluss/remote-data");
 
-        // set to small timout to verify the case that zk session is timeout
+        // set to small timeout to verify the case that zk session is timeout
         configuration.set(ConfigOptions.ZOOKEEPER_SESSION_TIMEOUT, Duration.ofMillis(500));
         configuration.set(ConfigOptions.ZOOKEEPER_CONNECTION_TIMEOUT, Duration.ofMillis(500));
         configuration.set(ConfigOptions.ZOOKEEPER_RETRY_WAIT, Duration.ofMillis(500));
diff --git a/fluss-server/src/test/java/org/apache/fluss/server/authorizer/DefaultAuthorizerTest.java b/fluss-server/src/test/java/org/apache/fluss/server/authorizer/DefaultAuthorizerTest.java
index a8ba299c020..43307fd2467 100644
--- a/fluss-server/src/test/java/org/apache/fluss/server/authorizer/DefaultAuthorizerTest.java
+++ b/fluss-server/src/test/java/org/apache/fluss/server/authorizer/DefaultAuthorizerTest.java
@@ -614,7 +614,7 @@ void testHighConcurrencyModificationOfResourceAcls() throws Exception {
         }
 
         runInConcurrent(concurrentTasks);
-        // Make sure all acl notifacations are arrived.
+        // Make sure all acl notifications are arrived.
         retry(
                 Duration.ofMinutes(1),
                 () -> assertThat(listAcls(authorizer, commonResource)).isEqualTo(expectedAcls));