You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by go...@apache.org on 2021/11/19 06:18:58 UTC
[flink] branch release-1.14 updated (dfa47af -> d3df986)
This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dfa47af [FLINK-23842][coordination] Add logging statements in SourceCoordinators for reader registration and split requests.
add d3df986 [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's inputs
No new revisions were added by this update.
Summary of changes:
.../planner/calcite/RelTimeIndicatorConverter.java | 4 +-
.../physical/stream/StreamPhysicalJoinRule.scala | 2 +-
.../planner/plan/utils/IntervalJoinUtil.scala | 17 ++-
.../flink/table/planner/plan/utils/JoinUtil.scala | 25 ++--
.../planner/plan/utils/TemporalJoinUtil.scala | 7 +-
.../table/planner/plan/utils/WindowJoinUtil.scala | 18 ++-
.../plan/stream/sql/join/IntervalJoinTest.xml | 130 +++++++++++++++++----
.../plan/stream/sql/join/IntervalJoinTest.scala | 15 +++
.../operators/join/window/WindowJoinOperator.java | 6 +-
9 files changed, 173 insertions(+), 51 deletions(-)