This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 01c8150 [hotfix][connectors] Fix: Infinite loop can arise when prepareCommit(flush=false) is called in AsyncSinkWriter with buffered elements add 2e340e0 [FLINK-25677][table-planner] Update ReplicateRows to the new type inference No new revisions were added by this update. Summary of changes: .../functions/BuiltInFunctionDefinitions.java | 10 +++ ...java => InternalReplicateRowsTypeStrategy.java} | 20 +++--- .../strategies/SpecificTypeStrategies.java | 4 ++ .../planner/plan/utils/SetOpRewriteUtil.scala | 72 +++++++--------------- .../planner/plan/batch/sql/SetOperatorsTest.xml | 8 +-- .../planner/plan/batch/table/SetOperatorsTest.xml | 8 +-- .../planner/plan/common/PartialInsertTest.xml | 16 ++--- .../rules/logical/RewriteIntersectAllRuleTest.xml | 12 ++-- .../plan/rules/logical/RewriteMinusAllRuleTest.xml | 12 ++-- .../planner/plan/stream/sql/SetOperatorsTest.xml | 8 +-- .../runtime/functions/table/ReplicateRows.java | 70 --------------------- .../ReplicateRowsFunction.java} | 36 +++++++---- 12 files changed, 102 insertions(+), 174 deletions(-) copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{ArrayTypeStrategy.java => InternalReplicateRowsTypeStrategy.java} (72%) delete mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/ReplicateRows.java copy flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/{scalar/IfNullFunction.java => table/ReplicateRowsFunction.java} (50%)