diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java
index b909e0afa1986..68dbbb1c48598 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java
@@ -36,7 +36,7 @@
 import org.apache.flink.table.planner.plan.trait.MiniBatchInterval;
 import org.apache.flink.table.planner.plan.trait.MiniBatchMode;
 import org.apache.flink.table.runtime.operators.wmassigners.ProcTimeMiniBatchAssignerOperator;
-import org.apache.flink.table.runtime.operators.wmassigners.RowTimeMiniBatchAssginerOperator;
+import org.apache.flink.table.runtime.operators.wmassigners.RowTimeMiniBatchAssignerOperator;
 import org.apache.flink.table.runtime.typeutils.InternalTypeInfo;
 import org.apache.flink.table.types.logical.RowType;
 
@@ -113,7 +113,7 @@ protected Transformation<RowData> translateToPlanInternal(
         if (miniBatchInterval.getMode() == MiniBatchMode.ProcTime) {
             operator = new ProcTimeMiniBatchAssignerOperator(miniBatchInterval.getInterval());
         } else if (miniBatchInterval.getMode() == MiniBatchMode.RowTime) {
-            operator = new RowTimeMiniBatchAssginerOperator(miniBatchInterval.getInterval());
+            operator = new RowTimeMiniBatchAssignerOperator(miniBatchInterval.getInterval());
         } else {
             throw new TableException(
                     String.format(
diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/ProcTimeMiniBatchAssignerOperator.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/ProcTimeMiniBatchAssignerOperator.java
index ab0f0f34b3a1e..04110f3e2b7b4 100644
--- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/ProcTimeMiniBatchAssignerOperator.java
+++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/ProcTimeMiniBatchAssignerOperator.java
@@ -34,7 +34,7 @@
  *
  * <p>NOTE: currently, we use {@link Watermark} to represents the mini-batch marker.
  *
- * <p>The difference between this operator and {@link RowTimeMiniBatchAssginerOperator} is that,
+ * <p>The difference between this operator and {@link RowTimeMiniBatchAssignerOperator} is that,
  * this operator generates watermarks by itself using processing time, but the other forwards
  * watermarks from upstream.
  */
diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperator.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssignerOperator.java
similarity index 97%
rename from flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperator.java
rename to flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssignerOperator.java
index 079eec0b21ed3..edbbc8b6a9396 100644
--- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperator.java
+++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssignerOperator.java
@@ -41,7 +41,7 @@
  * this operator forwards watermarks from upstream, but the other generates watermarks by itself
  * using processing time.
  */
-public class RowTimeMiniBatchAssginerOperator extends AbstractStreamOperator<RowData>
+public class RowTimeMiniBatchAssignerOperator extends AbstractStreamOperator<RowData>
         implements OneInputStreamOperator<RowData, RowData> {
 
     private static final long serialVersionUID = 1L;
@@ -55,7 +55,7 @@ public class RowTimeMiniBatchAssginerOperator extends AbstractStreamOperator<Row
     /** The next watermark to be emitted. */
     private transient long nextWatermark;
 
-    public RowTimeMiniBatchAssginerOperator(long minibatchInterval) {
+    public RowTimeMiniBatchAssignerOperator(long minibatchInterval) {
         this.minibatchInterval = minibatchInterval;
     }
 
diff --git a/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperatorTest.java b/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssignerOperatorTest.java
similarity index 93%
rename from flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperatorTest.java
rename to flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssignerOperatorTest.java
index 43a26955e96fc..33bfcfbdbc7bb 100644
--- a/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperatorTest.java
+++ b/flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/wmassigners/RowTimeMiniBatchAssignerOperatorTest.java
@@ -32,12 +32,12 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-/** Tests of {@link RowTimeMiniBatchAssginerOperator}. */
-class RowTimeMiniBatchAssginerOperatorTest extends WatermarkAssignerOperatorTestBase {
+/** Tests of {@link RowTimeMiniBatchAssignerOperator}. */
+class RowTimeMiniBatchAssignerOperatorTest extends WatermarkAssignerOperatorTestBase {
 
     @Test
     void testRowTimeWatermarkAssigner() throws Exception {
-        final RowTimeMiniBatchAssginerOperator operator = new RowTimeMiniBatchAssginerOperator(5);
+        final RowTimeMiniBatchAssignerOperator operator = new RowTimeMiniBatchAssignerOperator(5);
         OneInputStreamOperatorTestHarness<RowData, RowData> testHarness =
                 new OneInputStreamOperatorTestHarness<>(operator);
         testHarness.open();
@@ -86,7 +86,7 @@ void testRowTimeWatermarkAssigner() throws Exception {
 
     @Test
     void testEndWatermarkIsForwarded() throws Exception {
-        final RowTimeMiniBatchAssginerOperator operator = new RowTimeMiniBatchAssginerOperator(50);
+        final RowTimeMiniBatchAssignerOperator operator = new RowTimeMiniBatchAssignerOperator(50);
         OneInputStreamOperatorTestHarness<RowData, RowData> testHarness =
                 new OneInputStreamOperatorTestHarness<>(operator);
         testHarness.open();