William Saar created FLINK-2355:
-----------------------------------
Summary: Job hanging in collector, waiting for request buffer
Key: FLINK-2355
URL:
https://issues.apache.org/jira/browse/FLINK-2355 Project: Flink
Issue Type: Bug
Affects Versions: master
Reporter: William Saar
Running locally on a machine with 8 threads.
Daemon Thread [Flat Map -> (Filter, Filter -> Flat Map -> Filter -> (Stream Sink, Stream Sink)) (6/8)] (Suspended)
owns: SpanningRecordSerializer<T> (id=533)
waited by: Daemon Thread [Thread-173] (Suspended)
waiting for: ArrayDeque<E> (id=534)
Object.wait(long) line: not available [native method]
LocalBufferPool.requestBuffer(boolean) line: 163
LocalBufferPool.requestBufferBlocking() line: 133
StreamRecordWriter<T>(RecordWriter<T>).emit(T) line: 92
StreamRecordWriter<T>.emit(T) line: 58
StreamOutput<OUT>.collect(OUT) line: 62
CollectorWrapper<OUT>.collect(OUT) line: 40
StreamFilter<IN>.processElement(IN) line: 34
OutputHandler$CopyingOperatorCollector<T>.collect(T) line: 278
CollectorWrapper<OUT>.collect(OUT) line: 40
IteratedDataModelOp<I,O>.lambda$0(Collector, InternalMessage) line: 102
437981089.accept(Object) line: not available
ArrayList<E>.forEach(Consumer<? super E>) line: not available
IteratedDataModelOp<I,O>.processInput(I, Collector<MessageWrapper<I,O>>) line: 99
IteratedDataModelOp<I,O>.flatMap(MessageWrapper<I,O>, Collector<MessageWrapper<I,O>>) line: 70
IteratedDataModelOp<I,O>.flatMap(Object, Collector) line: 1
StreamFlatMap<IN,OUT>.processElement(IN) line: 35
OneInputStreamTask<IN,OUT>.invoke() line: 103
Task.run() line: 567
Thread.run() line: not available
Daemon Thread [Thread-173] (Suspended)
waiting for: SpanningRecordSerializer<T> (id=533)
owned by: Daemon Thread [Flat Map -> (Filter, Filter -> Flat Map -> Filter -> (Stream Sink, Stream Sink)) (6/8)] (Suspended)
waiting for: ArrayDeque<E> (id=534)
StreamRecordWriter<T>(RecordWriter<T>).flush() line: 149
StreamRecordWriter$OutputFlusher.run() line: 90
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
Locked
