This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3509a21 [FLINK-25839][e2e] Print the previous logs of restarted pod
for k8s e2e tests
add 2e910a6 [FLINK-25895][table-planner] Split
ExecNodeGraphJsonPlanGenerator and add ExecNodeGraph ser/de for intermediate
JsonPlanGraph representation
No new revisions were added by this update.
Summary of changes:
.../table/planner/plan/nodes/exec/ExecEdge.java | 5 +-
.../planner/plan/nodes/exec/ExecNodeGraph.java | 20 --
.../plan/nodes/exec/ExecNodeGraphValidator.java | 39 +++
...zer.java => ExecNodeGraphJsonDeserializer.java} | 29 +-
.../exec/serde/ExecNodeGraphJsonPlanGenerator.java | 299 ---------------------
...lizer.java => ExecNodeGraphJsonSerializer.java} | 38 ++-
.../plan/nodes/exec/serde/JsonPlanEdge.java | 97 +++++++
.../plan/nodes/exec/serde/JsonPlanGraph.java | 167 ++++++++++++
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 3 +
.../table/planner/delegation/PlannerBase.scala | 10 +-
.../table/planner/delegation/StreamPlanner.scala | 5 +-
11 files changed, 353 insertions(+), 359 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeGraphValidator.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ObjectIdentifierJsonSerializer.java
=> ExecNodeGraphJsonDeserializer.java} (63%)
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ExecNodeGraphJsonPlanGenerator.java
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{WindowReferenceJsonSerializer.java
=> ExecNodeGraphJsonSerializer.java} (59%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonPlanEdge.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonPlanGraph.java
