[jira] [Created] (FLINK-8541) Mesos RM should recover from failover timeout

Eron Wright created FLINK-8541: --- Summary: Mesos RM should recover from failover timeout Key: FLINK-8541 URL: https://issues.apache.org/jira/browse/FLINK-8541 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8540) FileStateHandles must not attempt to delete their parent directory.

Stephan Ewen created FLINK-8540: --- Summary: FileStateHandles must not attempt to delete their parent directory. Key: FLINK-8540 URL: https://issues.apache.org/jira/browse/FLINK-8540 Project: Flink

[jira] [Created] (FLINK-8539) Introduce "CompletedCheckpointStorageLocation" to explicitly handle disposal of checkpoint storage locations

Stephan Ewen created FLINK-8539: --- Summary: Introduce "CompletedCheckpointStorageLocation" to explicitly handle disposal of checkpoint storage locations Key: FLINK-8539 URL:

Re: Fwd: Re: Kinesis consumer shard skew - FLINK-8516

Hi Thomas, Thanks a lot for opening the PR. I had a look at it and the comment you left, and left my thoughts there. In general, I think it’s heading towards the right direction. Cheers, Gordon On 31 January 2018 at 4:03:36 PM, Thomas Weise (t...@apache.org) wrote: Hi Gordon, Can you have a

[jira] [Created] (FLINK-8538) Add a Kafka table source factory with JSON format support

Timo Walther created FLINK-8538: --- Summary: Add a Kafka table source factory with JSON format support Key: FLINK-8538 URL: https://issues.apache.org/jira/browse/FLINK-8538 Project: Flink Issue

[jira] [Created] (FLINK-8537) Add a Kafka table source factory with Avro format support

Timo Walther created FLINK-8537: --- Summary: Add a Kafka table source factory with Avro format support Key: FLINK-8537 URL: https://issues.apache.org/jira/browse/FLINK-8537 Project: Flink Issue

[jira] [Created] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties

Timo Walther created FLINK-8536: --- Summary: Improve CSVTableSourceFactory to support all descriptor properties Key: FLINK-8536 URL: https://issues.apache.org/jira/browse/FLINK-8536 Project: Flink

[jira] [Created] (FLINK-8535) Implement a basic set of table source factories

Timo Walther created FLINK-8535: --- Summary: Implement a basic set of table source factories Key: FLINK-8535 URL: https://issues.apache.org/jira/browse/FLINK-8535 Project: Flink Issue Type: New

Re: [DISCUSS] Releasing Flink 1.4.1

Thanks a lot for the wrap-up Chesnay. For open issues with a PR already: [FLINK-8275] Flink YARN TMs using wrong local Kerberos keytab path  [FLINK-8318] Shade all Elasticsearch connector dependencies  I am currently reviewing these two. [FLINK-8409] KafkaConsumerThread potential NPE 

[jira] [Created] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration. Will cause Caused by: java.io.FileNotFoundException release file error

zhu.qing created FLINK-8534: --- Summary: if insert too much BucketEntry into one bucket in join of iteration. Will cause Caused by: java.io.FileNotFoundException release file error Key: FLINK-8534 URL:

[DISCUSS] Releasing Flink 1.5.0

Hi Everyone, When we decided to do the 1.4.0 release a while back we did that to get a stable release out before putting in a couple of new features. Back then, some of those new features (FLIP-6, network stack changes, local state recovery) were almost ready and we wanted to do a shortened

[jira] [Created] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

Eron Wright created FLINK-8533: --- Summary: Support MasterTriggerRestoreHook state reinitialization Key: FLINK-8533 URL: https://issues.apache.org/jira/browse/FLINK-8533 Project: Flink Issue