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%)
