You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/07/04 05:53:49 UTC
[3/8] flink git commit: [hotfix][network] checkstyle
[hotfix][network] checkstyle
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c314dd1e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c314dd1e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c314dd1e
Branch: refs/heads/release-1.5
Commit: c314dd1eab768e72ab9ebc8bb9d2641610dc21d2
Parents: 9198adc
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Mon Jul 2 11:50:47 2018 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Jul 4 07:52:56 2018 +0200
----------------------------------------------------------------------
.../flink/runtime/io/network/buffer/NetworkBufferPool.java | 4 ++--
.../flink/runtime/io/network/buffer/NetworkBufferPoolTest.java | 3 +++
2 files changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c314dd1e/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
index 7b817ca..7a5832a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
@@ -42,7 +42,7 @@ import static org.apache.flink.util.Preconditions.checkArgument;
* The NetworkBufferPool is a fixed size pool of {@link MemorySegment} instances
* for the network stack.
*
- * The NetworkBufferPool creates {@link LocalBufferPool}s from which the individual tasks draw
+ * <p>The NetworkBufferPool creates {@link LocalBufferPool}s from which the individual tasks draw
* the buffers for the network data transfer. When new local buffer pools are created, the
* NetworkBufferPool dynamically redistributes the buffers between the pools.
*/
@@ -70,7 +70,7 @@ public class NetworkBufferPool implements BufferPoolFactory {
* Allocates all {@link MemorySegment} instances managed by this pool.
*/
public NetworkBufferPool(int numberOfSegmentsToAllocate, int segmentSize) {
-
+
this.totalNumberOfMemorySegments = numberOfSegmentsToAllocate;
this.memorySegmentSize = segmentSize;
http://git-wip-us.apache.org/repos/asf/flink/blob/c314dd1e/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
index 739a4d6..f1c5d0b 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
@@ -42,6 +42,9 @@ import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+/**
+ * Tests for {@link NetworkBufferPool}.
+ */
public class NetworkBufferPoolTest {
@Rule