Re: TaskManager deadlock on NetworkBufferPool

Please use this link. https://gist.github.com/imamitjain/5ab84c2d9eaf06615ad912506a08f7e2 On Thu, Apr 19, 2018 at 10:37 PM, Ted Yu wrote: > Amit: > Execution plan attachment didn't come through. > > Please consider using third party website for storing the plan. > > FYI >

Re: TaskManager deadlock on NetworkBufferPool

Amit: Execution plan attachment didn't come through. Please consider using third party website for storing the plan. FYI On Thu, Apr 19, 2018 at 10:04 AM, Amit Jain wrote: > @Ufuk Please find execution plan in the attachment. > > @Nico Job is not making progress at all.

Re: TaskManager deadlock on NetworkBufferPool

@Ufuk Please find execution plan in the attachment. @Nico Job is not making progress at all. This issue is happening randomly. Few of our jobs are working with only few MB of data and still, they are getting stuck even TM have 22G with 2 slots per TM. I've started using 1.5 and facing few issues

[jira] [Created] (FLINK-9223) bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd

Ted Yu created FLINK-9223: - Summary: bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd Key: FLINK-9223 URL: https://issues.apache.org/jira/browse/FLINK-9223

[jira] [Created] (FLINK-9222) Add a Gradle Quickstart

Nico Kruber created FLINK-9222: -- Summary: Add a Gradle Quickstart Key: FLINK-9222 URL: https://issues.apache.org/jira/browse/FLINK-9222 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9221) Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]

Josh Lemer created FLINK-9221: - Summary: Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B] Key: FLINK-9221 URL: https://issues.apache.org/jira/browse/FLINK-9221 Project: Flink

[jira] [Created] (FLINK-9220) Table program cannot be compiled

Saurabh Garg created FLINK-9220: --- Summary: Table program cannot be compiled Key: FLINK-9220 URL: https://issues.apache.org/jira/browse/FLINK-9220 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

Timo Walther created FLINK-9219: --- Summary: Add support for OpenGIS features in Table & SQL API Key: FLINK-9219 URL: https://issues.apache.org/jira/browse/FLINK-9219 Project: Flink Issue Type:

[jira] [Created] (FLINK-9218) Docs for old versions aren't building successfully

Chesnay Schepler created FLINK-9218: --- Summary: Docs for old versions aren't building successfully Key: FLINK-9218 URL: https://issues.apache.org/jira/browse/FLINK-9218 Project: Flink Issue