This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from bbb9e70 [FLINK-15369][runtime] Set MiniCluster to use fixed managed /
shuffle memory size by default.
add 13a5cf9 [FLINK-14200][table] Fix NPE for Temporal Table Function Join
when left side is a query instead of a source (#10763)
No new revisions were added by this update.
Summary of changes:
.../catalog/QueryOperationCatalogViewTable.java | 2 +-
.../table/planner/calcite/FlinkRelBuilder.scala | 4 +-
...relateToJoinFromTemporalTableFunctionRule.scala | 17 +++-
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 44 ++++++++++
.../plan/stream/sql/join/TemporalJoinTest.xml | 27 ++++++
.../stream/sql/MiniBatchIntervalInferTest.scala | 3 +-
.../plan/stream/sql/join/TemporalJoinTest.scala | 14 ++++
.../runtime/stream/sql/TemporalJoinITCase.scala | 93 +++++++++++++++++++--
.../catalog/QueryOperationCatalogViewTable.java | 2 +-
.../flink/table/calcite/FlinkRelBuilder.scala | 4 +-
.../LogicalCorrelateToTemporalTableJoinRule.scala | 17 +++-
.../api/stream/sql/TemporalTableJoinTest.scala | 29 +++++++
.../runtime/stream/sql/TemporalJoinITCase.scala | 95 ++++++++++++++++++++--
13 files changed, 324 insertions(+), 27 deletions(-)
