Remove unused imports from RichMapPartitionFunction. Wrap way too long...

Remove unused imports from RichMapPartitionFunction. Wrap way too long statements in NetworkBufferPool.

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;
 
 /**

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() {