[jira] [Created] (FLINK-5388) Remove private access of edges and vertices of Gelly Graph class

wouter ligtenberg created FLINK-5388: Summary: Remove private access of edges and vertices of Gelly Graph class Key: FLINK-5388 URL: https://issues.apache.org/jira/browse/FLINK-5388 Project: Flink

[ANNOUNCE] Flink 1.1.4 Released

The Flink PMC is pleased to announce the availability of Flink 1.1.4. The official release announcement: https://flink.apache.org/news/2016/12/21/release-1.1.4.html Release binaries: http://apache.lauf-forum.at/flink/flink-1.1.4 Please update your Maven dependencies to the new 1.1.4 version and

Re: Flink gives incorrect result when event time windowing used

Yes, it would seem that the bounded-out-of-orderness extractor has an off-by-one error. We should fix it. In most practical cases these errors should not change results by much, however (IMHO). Cheers, Aljoscha On Wed, 21 Dec 2016 at 22:43 Jaromir Vanek wrote: > Aljoscha, thank you very much fo

Dynamic Scaling

Hi, We have a computation heavy streaming flink job which will be processing around 100 million message at peak time and around 1 million messages in non peak time. We need the capability to dynamically scale so that the computation operator can scale up and down during high or low work loads resp

Getting started with FLINK-4088

Hi all, I would like to work on above mentioned issue [1]. Could someone please provide more details about it, like where should I work on the source code etc? Thanks! Minudika

Re: Getting started with FLINK-4088

Hi all, I would like to work on above mentioned issue [1]. Could someone please provide more details about it, like where should I work on the source code etc? [1] https://issues.apache.org/jira/browse/FLINK-4088 P.S : Added the URL of the JIRA ticket Thanks! On Sat, Dec 24, 2016 at 2:49 AM, M

[jira] [Created] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

Anton Solovev created FLINK-5389: Summary: Fails #testAnswerFailureWhenSavepointReadFails Key: FLINK-5389 URL: https://issues.apache.org/jira/browse/FLINK-5389 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] Flink 1.1.4 Released

Thank you Ufuk for your work as release manager and everybody who contributed! Cheers, Fabian 2016-12-23 16:40 GMT+01:00 Ufuk Celebi : > The Flink PMC is pleased to announce the availability of Flink 1.1.4. > > The official release announcement: > https://flink.apache.org/news/2016/12/21/release

Re: Status of Flink-Calcite integration

Hi Haohui, sorry for the delayed reply. Defining joins and windowing on streams with SQL is certainly on the road map of Flink. However, the challenge here is not so much in mapping RelNodes to Flink's DataStream operators. It is rather to have the right SQL syntax and semantics to define common

[jira] [Created] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

Ted Yu created FLINK-5390: - Summary: input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph() Key: FLINK-5390 URL: https://issues.apache.org/jira/browse/FLINK-5390 Project: F

[jira] [Created] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

Ted Yu created FLINK-5391: - Summary: Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown() Key: FLINK-5391 URL: https://issues.apache.org/jira/browse/FLINK-5391 Project: Flink I