Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6308
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r202047581
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedBackendSerializationProxy.java
---
@@ -98,8 +103,7 @@ public int
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r202047403
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/SerializationProxiesTest.java
---
@@ -126,11 +131,11 @@ public void
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r202041046
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoSnapshotReadersWriters.java
---
@@ -0,0 +1,412 @@
+/*
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r201798531
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorBackendSerializationProxy.java
---
@@ -62,62 +67,62 @@ public int
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r202035286
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/SerializationProxiesTest.java
---
@@ -126,11 +131,11 @@ public void
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r202033136
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoSnapshotReadersWriters.java
---
@@ -0,0 +1,412 @@
+/*
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6308#discussion_r201778299
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedBackendSerializationProxy.java
---
@@ -98,8 +103,7 @@ public int getVersion() {
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/6308
[FLINK-9799] Generalize and unify state meta info snapshot
## What is the purpose of the change
This PR generalizes and unifies the de/serialization of state meta
information in
