[jira] [Created] (FLINK-9129) Support nested KafkaJsonTableSource

samar created FLINK-9129: Summary: Support nested KafkaJsonTableSource Key: FLINK-9129 URL: https://issues.apache.org/jira/browse/FLINK-9129 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9130) Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs

Fabian Hueske created FLINK-9130: Summary: Add cancel-job option to SavepointHandlers JavaDoc and regenerate REST docs Key: FLINK-9130 URL: https://issues.apache.org/jira/browse/FLINK-9130 Project:

[jira] [Created] (FLINK-9131) Disable spotbugs on travis

Chesnay Schepler created FLINK-9131: --- Summary: Disable spotbugs on travis Key: FLINK-9131 URL: https://issues.apache.org/jira/browse/FLINK-9131 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9134) Update Calcite dependency to 1.17

Timo Walther created FLINK-9134: --- Summary: Update Calcite dependency to 1.17 Key: FLINK-9134 URL: https://issues.apache.org/jira/browse/FLINK-9134 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9132) Cluster runs out of task slots when a job falls into restart loop

Alex Smirnov created FLINK-9132: --- Summary: Cluster runs out of task slots when a job falls into restart loop Key: FLINK-9132 URL: https://issues.apache.org/jira/browse/FLINK-9132 Project: Flink

[jira] [Created] (FLINK-9133) Improve documentability of REST API

Chesnay Schepler created FLINK-9133: --- Summary: Improve documentability of REST API Key: FLINK-9133 URL: https://issues.apache.org/jira/browse/FLINK-9133 Project: Flink Issue Type:

[jira] [Created] (FLINK-9135) Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed

Fabian Hueske created FLINK-9135: Summary: Remove AggregateReduceFunctionsRule once CALCITE-2216 is fixed Key: FLINK-9135 URL: https://issues.apache.org/jira/browse/FLINK-9135 Project: Flink

Re: TaskManager deadlock on NetworkBufferPool

+u...@flink.apache.org On Wed, Apr 4, 2018 at 11:33 AM, Amit Jain wrote: > Hi, > > We are hitting TaskManager deadlock on NetworkBufferPool bug in Flink 1.3.2. > We have set of ETL's merge jobs for a number of tables and stuck with above > issue randomly daily. > > I'm

[jira] [Created] (FLINK-9136) Remove StreamingProgramTestBase

Chesnay Schepler created FLINK-9136: --- Summary: Remove StreamingProgramTestBase Key: FLINK-9136 URL: https://issues.apache.org/jira/browse/FLINK-9136 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9137) Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase

Chesnay Schepler created FLINK-9137: --- Summary: Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase Key: FLINK-9137 URL: https://issues.apache.org/jira/browse/FLINK-9137 Project: Flink

[jira] [Created] (FLINK-9138) Enhance BucketingSink to also flush data by time interval

Narayanan Arunachalam created FLINK-9138: Summary: Enhance BucketingSink to also flush data by time interval Key: FLINK-9138 URL: https://issues.apache.org/jira/browse/FLINK-9138 Project:

Re: TaskManager deadlock on NetworkBufferPool

I searched for 0x0005e28fe218 in the two files you attached to FLINK-2685 but didn't find any hit. Was this the same instance as the attachment to FLINK-2685 ? Thanks On Wed, Apr 4, 2018 at 10:21 AM, Amit Jain wrote: > +u...@flink.apache.org > > On Wed, Apr 4, 2018 at

Re: TaskManager deadlock on NetworkBufferPool

Hi Amit, The network stack has been redesigned for the upcoming Flink 1.5 release. The issue might have been fixed by that. There's already a first release candidate for Flink 1.5.0 available [1]. It would be great if you would have the chance to check if the bug is still present. Best, Fabian

TaskManager deadlock on NetworkBufferPool

Hi, We are hitting TaskManager deadlock on NetworkBufferPool bug in Flink 1.3.2. We have set of ETL's merge jobs for a number of tables and stuck with above issue randomly daily. I'm attaching the thread dump of JobManager and one of the Task

[jira] [Created] (FLINK-9128) Add support for scheduleRunAsync for FencedRpcEndpoints

Till Rohrmann created FLINK-9128: Summary: Add support for scheduleRunAsync for FencedRpcEndpoints Key: FLINK-9128 URL: https://issues.apache.org/jira/browse/FLINK-9128 Project: Flink Issue