Repository: flink Updated Branches: refs/heads/master 92e809d1b -> 378b487c4
Remove unused imports from RichMapPartitionFunction. Wrap way too long statements in NetworkBufferPool. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/378b487c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/378b487c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/378b487c Branch: refs/heads/master Commit: 378b487c4372f5a4cd51e356361b027e66d6225f Parents: 92e809d Author: Henry Saputra <[email protected]> Authored: Thu Mar 12 15:50:16 2015 -0700 Committer: Henry Saputra <[email protected]> Committed: Thu Mar 12 15:50:16 2015 -0700 ---------------------------------------------------------------------- .../flink/api/common/functions/RichMapPartitionFunction.java | 3 --- .../flink/runtime/io/network/buffer/NetworkBufferPool.java | 6 ++++-- 2 files changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/378b487c/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapPartitionFunction.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapPartitionFunction.java b/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapPartitionFunction.java index 4c288ca..d8b7e9b 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapPartitionFunction.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapPartitionFunction.java @@ -18,9 +18,6 @@ package org.apache.flink.api.common.functions; -import org.apache.flink.api.common.functions.AbstractRichFunction; -import org.apache.flink.api.common.functions.MapPartitionFunction; -import org.apache.flink.api.common.functions.RichFunction; import org.apache.flink.util.Collector; /** http://git-wip-us.apache.org/repos/asf/flink/blob/378b487c/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 8de7c36..3a6dbf5 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 @@ -74,12 +74,14 @@ public class NetworkBufferPool implements BufferPoolFactory { int allocatedMb = ((availableMemorySegments.size()) * segmentSize) >> 20; int missingMb = requiredMb - allocatedMb; - throw new OutOfMemoryError("Could not allocate enough memory segments for GlobalBufferPool (required (Mb): " + requiredMb + ", allocated (Mb): " + allocatedMb + ", missing (Mb): " + missingMb + ")."); + throw new OutOfMemoryError("Could not allocate enough memory segments for GlobalBufferPool (required (Mb): " + + requiredMb + ", allocated (Mb): " + allocatedMb + ", missing (Mb): " + missingMb + ")."); } int allocatedMb = ((availableMemorySegments.size()) * segmentSize) >> 20; - LOG.info("Allocated {} MB for network buffer pool (number of memory segments: {}, bytes per segment: {}).", allocatedMb, availableMemorySegments.size(), segmentSize); + LOG.info("Allocated {} MB for network buffer pool (number of memory segments: {}, bytes per segment: {}).", + allocatedMb, availableMemorySegments.size(), segmentSize); } public MemorySegment requestMemorySegment() {
