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 423143c [FLINK-25574][connectors/async] Migrate AsyncSink connectors
to decomposed SinkV2
add 54cedcb [hotfix][annotations] Add FlinkVersion#current
add 009d255 [FLINK-26055][table] Use FlinkVersion rather than version
string from core in persisted plan
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/flink/FlinkVersion.java | 5 ++
.../org/apache/flink/table/api/CompiledPlan.java | 3 +-
.../planner/plan/ExecNodeGraphCompiledPlan.java | 3 +-
.../planner/plan/nodes/exec/ExecNodeGraph.java | 10 ++--
...izer.java => FlinkVersionJsonDeserializer.java} | 26 +++++------
...alizer.java => FlinkVersionJsonSerializer.java} | 14 +++---
.../plan/nodes/exec/serde/JsonPlanGraph.java | 5 +-
.../plan/nodes/exec/serde/JsonSerdeUtil.java | 3 ++
.../apache/flink/table/api/CompiledPlanITCase.java | 13 ++++--
.../exec/serde/FlinkVersionJsonSerdeTest.java | 53 ++++++++++++++++++++++
.../flink/table/planner/utils/JsonTestUtils.java | 29 ++++++------
11 files changed, 119 insertions(+), 45 deletions(-)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ExecNodeGraphJsonDeserializer.java
=> FlinkVersionJsonDeserializer.java} (64%)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ObjectIdentifierJsonSerializer.java
=> FlinkVersionJsonSerializer.java} (77%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/FlinkVersionJsonSerdeTest.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/RawJsonDeserializer.java
=>
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/utils/JsonTestUtils.java
(53%)
