This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 9635730 [FLINK-21136] Adjust timeouts for reactive mode
add 6e17e8a [hotfix] remove useless code in PlannerBase
add 31df1f3 [FLINK-21868][table-planner-blink] Support
StreamExecLookupJoin json serialization/deserialization
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/batch/BatchExecLookupJoin.java | 18 +-
.../nodes/exec/common/CommonExecLookupJoin.java | 117 +++--
.../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 18 +-
.../nodes/exec/spec/DynamicTableSourceSpec.java | 6 +
.../nodes/exec/spec/TemporalTableSourceSpec.java | 126 +++++
.../nodes/exec/stream/StreamExecLookupJoin.java | 51 +-
.../table/planner/plan/utils/LookupJoinUtil.java | 75 ++-
.../planner/codegen/LookupJoinCodeGenerator.scala | 21 +-
.../table/planner/delegation/PlannerBase.scala | 3 +-
.../physical/batch/BatchPhysicalLookupJoin.scala | 19 +-
.../physical/stream/StreamPhysicalLookupJoin.scala | 30 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 13 +-
...BoundSerdeTest.java => LookupKeySerdeTest.java} | 78 ++--
.../serde/TemporalTableSourceSpecSerdeTest.java | 131 ++++++
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 1 -
...onPlanTest.java => LookupJoinJsonPlanTest.java} | 50 +-
.../stream/jsonplan/LookupJoinJsonPlanITCase.java | 96 ++++
.../testJoinTemporalTable.out} | 514 ++++++++++-----------
...estJoinTemporalTableWithProjectionPushDown.out} | 443 +++++++++---------
.../plan/batch/sql/join/LookupJoinTest.scala | 3 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 4 +-
21 files changed, 1181 insertions(+), 636 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/TemporalTableSourceSpec.java
copy
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{RexWindowBoundSerdeTest.java
=> LookupKeySerdeTest.java} (51%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/TemporalTableSourceSpecSerdeTest.java
copy
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{IntervalJoinJsonPlanTest.java
=> LookupJoinJsonPlanTest.java} (66%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/LookupJoinJsonPlanITCase.java
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{WindowAggregateJsonPlanTest_jsonplan/testEventTimeHopWindow.out
=> LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTable.out} (62%)
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{WindowAggregateJsonPlanTest_jsonplan/testProcTimeTumbleWindow.out
=>
LookupJoinJsonPlanTest_jsonplan/testJoinTemporalTableWithProjectionPushDown.out}
(63%)
