[hotfix] [core] Avoid array copying in LinkedOptionalMapSerializer

static-max · Mar 13, 2019 · d6b94e8 · d6b94e8
1 parent 939038f
commit d6b94e8
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java b/flink-core/src/main/java/org/apache/flink/util/LinkedOptionalMapSerializer.java
@@ -113,9 +113,10 @@ private static <T> void writeFramed(DataOutputView out, BiConsumerWithException<
  DataOutputSerializer frame = new DataOutputSerializer(64);
  writer.accept(frame, item);
 
- final byte[] buffer = frame.getCopyOfBuffer();
- out.writeInt(buffer.length);
- out.write(buffer);
+ final byte[] buffer = frame.getSharedBuffer();
+ final int bufferSize = frame.length();
+ out.writeInt(bufferSize);
+ out.write(buffer, 0, bufferSize);
  }
 
  @Nullable