[jira] [Created] (FLINK-7578) WindowStream should support rich AggregateFunction

Hequn Cheng created FLINK-7578: -- Summary: WindowStream should support rich AggregateFunction Key: FLINK-7578 URL: https://issues.apache.org/jira/browse/FLINK-7578 Project: Flink Issue Type: Impr

Question about Flink's savepoint

Hi all, I have some questions about the experience I had with the save point. So, last night I found my flink cluster's memory usage seemed wired, so I decided to 1. create a savepoint for the running job(there was only one job running at the time) 2. and then cancel the job from web UI 3. and re

[jira] [Created] (FLINK-7577) flink-core

Hai Zhou created FLINK-7577: --- Summary: flink-core Key: FLINK-7577 URL: https://issues.apache.org/jira/browse/FLINK-7577 Project: Flink Issue Type: Sub-task Components: Build System

[jira] [Created] (FLINK-7576) Add FutureUtils.retryWithDelay

Till Rohrmann created FLINK-7576: Summary: Add FutureUtils.retryWithDelay Key: FLINK-7576 URL: https://issues.apache.org/jira/browse/FLINK-7576 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-7575) Dashboard jobs/tasks metrics display 0 when metrics are not yet available

James Lafa created FLINK-7575: - Summary: Dashboard jobs/tasks metrics display 0 when metrics are not yet available Key: FLINK-7575 URL: https://issues.apache.org/jira/browse/FLINK-7575 Project: Flink

[jira] [Created] (FLINK-7574) flink-clients

Hai Zhou created FLINK-7574: --- Summary: flink-clients Key: FLINK-7574 URL: https://issues.apache.org/jira/browse/FLINK-7574 Project: Flink Issue Type: Sub-task Components: Build System

[jira] [Created] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

mingleizhang created FLINK-7573: --- Summary: Introduce Http protocol connector for Elasticsearch2 Key: FLINK-7573 URL: https://issues.apache.org/jira/browse/FLINK-7573 Project: Flink Issue Type:

Re: Sync Flink

Hi, The example in that talk doesn't sort elements by timestamp, only putting them into buckets (windows) is based on time and the processing of those buckets is triggered by an advancing watermark. Even with just one input it's not (easily) possible to sort elements by timestamp. However, it i

Re: Start contributing to Flink

I've responded in the JIRA issue threads for FLINK-2267 and FLINK-2269. Cheers, Till On Fri, Sep 1, 2017 at 7:02 PM, Mikhail Lipkovich < lipkovich.mikh...@gmail.com> wrote: > Thanks a lot Chesnay, > > Now I can assign issues to myself. > I really appreciate If someone can comment on FLINK-2267 a

Re: Streaming job gets slower and slower

Hi Aparup, the slow-down can have multiple reasons. One reason could be that your computation in Timeseries-Analytics becomes more complex over time and therefore it slows down resulting in back pressure at the sources. This could be, for example, caused by accumulating a large state. Here the que

Re: Quick start guide

Hi, Yes, I think this is wrong in the doc and should refer to the TaskManager logs. Best, Aljoscha > On 4. Sep 2017, at 03:56, Michael Fong wrote: > > Hi, > > I was following the quick start guide on official documents >