Repository: flink Updated Branches: refs/heads/master d45ed2972 -> 5050f9119
[FLINK-8522] [checkpoint] Remove number of states from checkpoint. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/44211e34 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/44211e34 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/44211e34 Branch: refs/heads/master Commit: 44211e346f43c931b6eb7106314a1686e25585d9 Parents: d45ed29 Author: kkloudas <[email protected]> Authored: Tue Jan 30 17:06:16 2018 +0100 Committer: kkloudas <[email protected]> Committed: Wed Feb 7 14:05:50 2018 +0100 ---------------------------------------------------------------------- .../apache/flink/runtime/state/DefaultOperatorStateBackend.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/44211e34/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java index c45b9e3..e6d6dc6 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java @@ -280,8 +280,6 @@ public class DefaultOperatorStateBackend implements OperatorStateBackend { backendSerializationProxy.write(dov); - dov.writeInt(registeredStatesDeepCopies.size()); - for (Map.Entry<String, PartitionableListState<?>> entry : registeredStatesDeepCopies.entrySet()) {
