[FLINK-4332] [checkpoints] Fix SavepointV1Serializer read() / readFul…

…ly()
kongxi · Aug 8, 2016 · 3f3bab1 · 3f3bab1
1 parent cd98e85
commit 3f3bab1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...me/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV1Serializer.java b/...me/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);
  }