[flink] branch master updated: [FLINK-28776][table-planner] RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream operator (#20417)

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jark 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 2a7fe42d506 [FLINK-28776][table-planner] RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream operator (#20417)
2a7fe42d506 is described below

commit 2a7fe42d5069a7f9d0d7c531011aaf622893064e
Author: Jacky Lau <li...@gmail.com>
AuthorDate: Wed Aug 3 20:35:30 2022 +0800

    [FLINK-28776][table-planner] RowTimeMiniBatchAssginerOperator doesn't need separate chain with upstream operator (#20417)
---
 .../runtime/operators/wmassigners/RowTimeMiniBatchAssginerOperator.java | 2 ++
 1 file changed, 2 insertions(+)

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/RowTimeMiniBatchAssginerOperator.java
index 079eec0b21e..d3e54980158 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/RowTimeMiniBatchAssginerOperator.java
@@ -19,6 +19,7 @@
 package org.apache.flink.table.runtime.operators.wmassigners;
 
 import org.apache.flink.streaming.api.operators.AbstractStreamOperator;
+import org.apache.flink.streaming.api.operators.ChainingStrategy;
 import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
 import org.apache.flink.streaming.api.watermark.Watermark;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
@@ -57,6 +58,7 @@ public class RowTimeMiniBatchAssginerOperator extends AbstractStreamOperator<Row
 
     public RowTimeMiniBatchAssginerOperator(long minibatchInterval) {
         this.minibatchInterval = minibatchInterval;
+        this.chainingStrategy = ChainingStrategy.ALWAYS;
     }
 
     @Override