This is an automated email from the ASF dual-hosted git repository.
davidradl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 690b6a3fff4 [hotfix][table-runtime] Fix typo in
RowTimeMiniBatchAssignerOperator class name (#28172)
690b6a3fff4 is described below
commit 690b6a3fff4483e98399011d40ca70f6c00e2289
Author: Dennis-Mircea Ciupitu <[email protected]>
AuthorDate: Thu Jun 4 12:29:02 2026 +0300
[hotfix][table-runtime] Fix typo in RowTimeMiniBatchAssignerOperator class
name (#28172)
---
.../plan/nodes/exec/stream/StreamExecMiniBatchAssigner.java | 4 ++--
.../operators/wmassigners/ProcTimeMiniBatchAssignerOperator.java | 2 +-
...ssginerOperator.java => RowTimeMiniBatchAssignerOperator.java} | 4 ++--
...peratorTest.java => RowTimeMiniBatchAssignerOperatorTest.java} | 8 ++++----
4 files changed, 9 insertions(+), 9 deletions(-)
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 b909e0afa19..68dbbb1c485 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.nodes.exec.utils.ExecNodeUtil;
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 @@ public class StreamExecMiniBatchAssigner extends
ExecNodeBase<RowData>
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 ab0f0f34b3a..04110f3e2b7 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 @@ import org.apache.flink.table.data.RowData;
*
* <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 079eec0b21e..edbbc8b6a93 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 @@ import org.apache.flink.table.data.RowData;
* 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 43a26955e96..33bfcfbdbc7 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 java.util.concurrent.ConcurrentLinkedQueue;
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 @@ class RowTimeMiniBatchAssginerOperatorTest extends
WatermarkAssignerOperatorTest
@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();
