flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [2/4] flink git commit: [network] Clear serializer only once in RecordWriter#flush()
Date Mon, 09 Jan 2017 15:24:44 GMT
[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 <nico@data-artisans.com>
Authored: Thu Nov 17 14:01:52 2016 +0100
Committer: Ufuk Celebi <uce@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();


Mime
View raw message