Repository: flink Updated Branches: refs/heads/master c53148628 -> c19df9ff6
[hotfix] [network] Rename RecordWriter#closeBufferConsumer() to closeBufferBuilder() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6abc8a93 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6abc8a93 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6abc8a93 Branch: refs/heads/master Commit: 6abc8a9333ffe72f65593d4859f1f10662068a1f Parents: c531486 Author: Nico Kruber <n...@data-artisans.com> Authored: Thu Feb 22 14:11:13 2018 +0100 Committer: Stephan Ewen <se...@apache.org> Committed: Fri Mar 9 16:49:39 2018 +0100 ---------------------------------------------------------------------- .../apache/flink/runtime/io/network/api/writer/RecordWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/6abc8a93/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java index 4ec2863..c35c7f3 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java @@ -175,7 +175,7 @@ public class RecordWriter<T extends IOReadableWritable> { public void clearBuffers() { for (int targetChannel = 0; targetChannel < numChannels; targetChannel++) { RecordSerializer<?> serializer = serializers[targetChannel]; - closeBufferConsumer(targetChannel); + closeBufferBuilder(targetChannel); serializer.clear(); } } @@ -213,7 +213,7 @@ public class RecordWriter<T extends IOReadableWritable> { return bufferBuilder; } - private void closeBufferConsumer(int targetChannel) { + private void closeBufferBuilder(int targetChannel) { if (bufferBuilders[targetChannel].isPresent()) { bufferBuilders[targetChannel].get().finish(); bufferBuilders[targetChannel] = Optional.empty();
