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 889b384 [FLINK-20130][core] Add ZStandard to FileInputFormat
add e2b7256 [FLINK-21704][table-planner-blink] Support json
serialization/deserialization for ChangelogSource
No new revisions were added by this update.
Summary of changes:
.../exec/stream/StreamExecChangelogNormalize.java | 32 ++++-
.../exec/stream/StreamExecDropUpdateBefore.java | 17 ++-
...nTest.java => ChangelogSourceJsonPlanTest.java} | 69 ++++-------
.../nodes/exec/stream/JsonSerdeCoverageTest.java | 2 -
.../jsonplan/ChangelogSourceJsonPlanITCase.java | 115 ++++++++++++++++++
.../table/planner/utils/JsonPlanTestBase.java | 5 +
.../testChangelogSource.out | 134 +++++++++++++++++++++
.../testUpsertSource.out} | 106 ++++++++--------
8 files changed, 376 insertions(+), 104 deletions(-)
copy
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{CalcJsonPlanTest.java
=> ChangelogSourceJsonPlanTest.java} (55%)
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/ChangelogSourceJsonPlanITCase.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/ChangelogSourceJsonPlanTest_jsonplan/testChangelogSource.out
copy
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/{TableSinkJsonPlanTest_jsonplan/testPartitioning.out
=> ChangelogSourceJsonPlanTest_jsonplan/testUpsertSource.out} (55%)
