You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/04/19 08:57:00 UTC
[3/4] flink git commit: [hotfix][network] minor optimisation in
LocalBufferPool
[hotfix][network] minor optimisation in LocalBufferPool
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a932ab86
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a932ab86
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a932ab86
Branch: refs/heads/master
Commit: a932ab8631fec8f9a670e7c0e5e9ef3b8a2b7f63
Parents: 75e5953
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Fri Apr 6 19:36:33 2018 +0200
Committer: Stefan Richter <s....@data-artisans.com>
Committed: Thu Apr 19 10:56:19 2018 +0200
----------------------------------------------------------------------
.../apache/flink/runtime/io/network/buffer/LocalBufferPool.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a932ab86/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
index fa15678..92a8e94 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
@@ -228,9 +228,7 @@ class LocalBufferPool implements BufferPool {
if (segment != null) {
numberOfRequestedMemorySegments++;
- availableMemorySegments.add(segment);
-
- continue;
+ return segment;
}
}