Support for Auto scaling

2017-02-01 Thread Meghashyam Sandeep V
Hi Guys, I currently run flink 1.1.4 streaming jobs in EMR in AWS with yarn. I understand that EMR supports auto scaling but Flink doesn't. Is there a plan for this support in 1.2. Thanks, Sandeep

[jira] [Created] (FLINK-5696) Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister

2017-02-01 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5696: - Summary: Access to REAPER_THREAD lacks proper synchronization in SafetyNetCloseableRegistry#doRegister Key: FLINK-5696 URL: https://issues.apache.org/jira/browse/FLINK-5696 Project

[jira] [Created] (FLINK-5695) Optimize table type systems based on database semantics

2017-02-01 Thread sunjincheng (JIRA)
sunjincheng created FLINK-5695: -- Summary: Optimize table type systems based on database semantics Key: FLINK-5695 URL: https://issues.apache.org/jira/browse/FLINK-5695 Project: Flink Issue Type:

RE: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-02-01 Thread Stefano Bortoli
Hi all, I was thinking to open a JIRA for the procTime() function so that it could be merged before and others could use it as well. What do you think? Regards, Stefano -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Friday, January 27, 2017 10:34 AM To: dev@fl