You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2017/01/09 15:24:44 UTC
[2/4] flink git commit: [network] Clear serializer only once in
RecordWriter#flush()
[network] Clear serializer only once in RecordWriter#flush()
This closes #2829.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a6b0fad
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4a6b0fad
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4a6b0fad
Branch: refs/heads/master
Commit: 4a6b0fad0909509cd1c37ed6e8d9dc7ec5d28d89
Parents: 161bab0
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Thu Nov 17 14:01:52 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Mon Jan 9 16:22:41 2017 +0100
----------------------------------------------------------------------
.../apache/flink/runtime/io/network/api/writer/RecordWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4a6b0fad/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 87d34ff..dfa2f3d 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
@@ -171,7 +171,7 @@ public class RecordWriter<T extends IOReadableWritable> {
Buffer buffer = serializer.getCurrentBuffer();
if (buffer != null) {
- writeAndClearBuffer(buffer, targetChannel, serializer);
+ targetPartition.writeBuffer(buffer, targetChannel);
}
} finally {
serializer.clear();