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 12aa1ad [FLINK-20460][hbase] Support async lookup for HBase connector
(#14684)
add 556942a [FLINK-21750][table-planner-blink] Support
StreamExecWatermarkAssigner json serialization/deserialization
No new revisions were added by this update.
Summary of changes:
.../exec/stream/StreamExecWatermarkAssigner.java | 35 +++++++-
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 1 -
.../stream/WatermarkAssignerJsonPlanTest.java} | 35 ++++----
.../jsonplan/WatermarkAssignerJsonPlanITCase.java | 67 +++++++++++++++
.../testWatermarkAssigner.out} | 95 +++++++++++++---------
5 files changed, 173 insertions(+), 60 deletions(-)
copy
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/{filesystem/FileSystemTableSourceTest.java
=> planner/plan/nodes/exec/stream/WatermarkAssignerJsonPlanTest.java} (66%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/WatermarkAssignerJsonPlanITCase.java
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{TableSourceJsonPlanTest_jsonplan/testWatermarkPushDown.out
=> WatermarkAssignerJsonPlanTest_jsonplan/testWatermarkAssigner.out} (60%)
