[FLINK-5326] [network] Log errors in sending Netty handler
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ed7752e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9ed7752e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9ed7752e Branch: refs/heads/release-1.1 Commit: 9ed7752eb0dc720fce190c2d4047c2abba157ef5 Parents: 04db15a Author: Ufuk Celebi <[email protected]> Authored: Tue Dec 13 11:26:47 2016 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Tue Dec 13 14:01:20 2016 +0100 ---------------------------------------------------------------------- .../flink/runtime/io/network/netty/PartitionRequestQueue.java | 2 ++ .../io/network/partition/PipelinedSubpartitionTest.java | 6 ------ 2 files changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/9ed7752e/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java index dc80675..297911a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java @@ -234,6 +234,8 @@ class PartitionRequestQueue extends ChannelInboundHandlerAdapter { } private void handleException(Channel channel, Throwable cause) throws IOException { + LOG.debug("Encountered error while consuming partitions", cause); + fatalError = true; releaseAllResources(); http://git-wip-us.apache.org/repos/asf/flink/blob/9ed7752e/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java index a97e306..e3200d1 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java @@ -19,14 +19,11 @@ 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; @@ -34,12 +31,9 @@ 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;
