flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hsapu...@apache.org
Subject flink git commit: Remove unused imports from RichMapPartitionFunction. Wrap way too long statements in NetworkBufferPool.
Date Thu, 12 Mar 2015 22:50:38 GMT
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 <henry.saputra@gmail.com>
Authored: Thu Mar 12 15:50:16 2015 -0700
Committer: Henry Saputra <henry.saputra@gmail.com>
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() {


Mime
View raw message