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

2018-01-31 Thread Eron Wright (JIRA)
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 Typ

[DISCUSS] Releasing Flink 1.5.0

2018-01-31 Thread Aljoscha Krettek
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 1.5

Re: [DISCUSS] Releasing Flink 1.4.1

2018-01-31 Thread Chesnay Schepler
Here's a list of all issues raised in this thread and their respective state: Unassigned: [FLINK-7756] RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP. [FLINK-7760] Restore failing from external checkpointing metadata. [FLINK-8042] retry individual failover-

[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

2018-01-31 Thread zhu.qing (JIRA)
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: https://issues.apa

Re: [DISCUSS] Releasing Flink 1.4.1

2018-01-31 Thread Tzu-Li (Gordon) Tai
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  [FLINK-841

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

2018-01-31 Thread Timo Walther (JIRA)
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 F

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

2018-01-31 Thread Timo Walther (JIRA)
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-8537) Add a Kafka table source factory with Avro format support

2018-01-31 Thread Timo Walther (JIRA)
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 T

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

2018-01-31 Thread Timo Walther (JIRA)
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 T

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

2018-01-31 Thread Tzu-Li (Gordon) Tai
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 q

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

2018-01-31 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-8539: --- Summary: Introduce "CompletedCheckpointStorageLocation" to explicitly handle disposal of checkpoint storage locations Key: FLINK-8539 URL: https://issues.apache.org/jira/browse/FLIN

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

2018-01-31 Thread Stephan Ewen (JIRA)
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

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

2018-01-31 Thread Thomas Weise
Thanks! I will cleanup the PR and then open it for review. -- sent from mobile On Jan 31, 2018 7:26 AM, "Tzu-Li (Gordon) Tai" wrote: > 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 to

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

2018-01-31 Thread Eron Wright (JIRA)
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