From 3f3bab10b9ca68eb31a7ef5a31e49145b51006fd Mon Sep 17 00:00:00 2001 From: Stephan Ewen Date: Mon, 8 Aug 2016 19:16:23 +0200 Subject: [PATCH] [FLINK-4332] [checkpoints] Fix SavepointV1Serializer read() / readFully() --- .../runtime/checkpoint/savepoint/SavepointV1Serializer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java index 8de29a657cd74..fcdc2cad89d9e 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java @@ -138,7 +138,7 @@ public SavepointV0 deserialize(DataInputStream dis) throws IOException { serializedValue = new SerializedValue<>(null); } else { byte[] serializedData = new byte[length]; - dis.read(serializedData, 0, length); + dis.readFully(serializedData, 0, length); serializedValue = SerializedValue.fromBytes(serializedData); } @@ -165,7 +165,7 @@ public SavepointV0 deserialize(DataInputStream dis) throws IOException { serializedValue = new SerializedValue<>(null); } else { byte[] serializedData = new byte[length]; - dis.read(serializedData, 0, length); + dis.readFully(serializedData, 0, length); serializedValue = SerializedValue.fromBytes(serializedData); }