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/03/20 02:40:23 UTC

[flink] branch master updated (3dd938d -> 6540cb6)

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 3dd938d  [FLINK-21602] Track asynchronous background tasks in the AdaptiveScheduler
     add 6540cb6  [FLINK-21816][table-planner-blink] Support StreamExecMatch json serialization/deserialization

No new revisions were added by this update.

Summary of changes:
 .../nodes/exec/serde/RexNodeJsonDeserializer.java  |  32 ++
 .../nodes/exec/serde/RexNodeJsonSerializer.java    |  16 +
 .../planner/plan/nodes/exec/spec/MatchSpec.java    |  77 +++-
 .../plan/nodes/exec/stream/StreamExecMatch.java    |  31 +-
 .../plan/nodes/exec/serde/RexNodeSerdeTest.java    |   4 +-
 .../nodes/exec/stream/JsonSerdeCoverageTest.java   |   1 -
 ...anTest.java => MatchRecognizeJsonPlanTest.java} |  42 +-
 .../jsonplan/MatchRecognizeJsonPlanITCase.java     | 109 +++++
 .../testMatch.out                                  | 501 +++++++++++++++++++++
 9 files changed, 776 insertions(+), 37 deletions(-)
 copy flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{RankJsonPlanTest.java => MatchRecognizeJsonPlanTest.java} (63%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/MatchRecognizeJsonPlanITCase.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/stream/MatchRecognizeJsonPlanTest_jsonplan/testMatch.out