[FLINK-5326] [network] Log errors in sending Netty handler

Adebski · Dec 13, 2016 · 9ed7752 · 9ed7752
1 parent 04db15a
commit 9ed7752
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/...untime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java b/...untime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
@@ -234,6 +234,8 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws E
 	}
 
 	private void handleException(Channel channel, Throwable cause) throws IOException {
+		LOG.debug("Encountered error while consuming partitions", cause);
+
 		fatalError = true;
 		releaseAllResources();
 

diff --git a/...rc/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java b/...rc/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java
@@ -19,27 +19,21 @@
 package org.apache.flink.runtime.io.network.partition;
 
 import org.apache.flink.core.memory.MemorySegment;
-import org.apache.flink.core.memory.MemorySegmentFactory;
 import org.apache.flink.runtime.event.AbstractEvent;
 import org.apache.flink.runtime.io.network.buffer.Buffer;
 import org.apache.flink.runtime.io.network.buffer.BufferProvider;
-import org.apache.flink.runtime.io.network.buffer.BufferRecycler;
 import org.apache.flink.runtime.io.network.partition.consumer.BufferOrEvent;
 import org.apache.flink.runtime.io.network.util.TestConsumerCallback;
-import org.apache.flink.runtime.io.network.util.TestInfiniteBufferProvider;
 import org.apache.flink.runtime.io.network.util.TestPooledBufferProvider;
 import org.apache.flink.runtime.io.network.util.TestProducerSource;
 import org.apache.flink.runtime.io.network.util.TestSubpartitionConsumer;
 import org.apache.flink.runtime.io.network.util.TestSubpartitionProducer;
 import org.junit.AfterClass;
 import org.junit.Test;
 
-import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.atomic.AtomicLong;
 
 import static org.apache.flink.runtime.io.network.util.TestBufferFactory.createBuffer;
 import static org.junit.Assert.assertEquals;