This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d3df986 [FLINK-24835][table-planner] Fix bug in
`RelTimeIndicatorConverter` when materialize time attribute fields of regular
join's inputs
add 3719c04 [FLINK-24608][table-planner][table-runtime] Insert rowtime
into StreamRecord for SinkProviders
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/common/CommonExecSink.java | 22 +-
.../plan/nodes/exec/stream/StreamExecMatch.java | 13 +-
.../nodes/exec/common/CommonExecSinkITCase.java | 281 +++++++++++++++++++++
.../operators/match/RowtimeProcessFunction.java | 60 -----
.../StreamRecordTimestampInserter.java} | 44 ++--
5 files changed, 325 insertions(+), 95 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSinkITCase.java
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/match/RowtimeProcessFunction.java
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/{sort/LimitOperator.java
=> sink/StreamRecordTimestampInserter.java} (55%)
