Re: [DISCUSS] Flink 1.6 features

2018-06-24 Thread zhangminglei
Hi, Community By the way, there is a very important feature I think it should be. Currently, the BucketingSink does not support when a bucket is ready for user use. This situation will be very obvious when flink work with offline end. We called that real time/offline integration in business. In

Re: Is it reasonable to use Flink in a local machine

2018-06-24 Thread zhangminglei
You are welcome, please let me know if you still have question. > 在 2018年6月25日,上午1:43,Soheil Pourbafrani 写道: > > Thanks for verification! > > On Sun, Jun 24, 2018 at 2:25 PM, zhangminglei <18717838...@163.com > > wrote: > Hi, Soheil > > You can set up several tas

[jira] [Created] (FLINK-9653) Add operator name to latency metrics

2018-06-24 Thread Julian Stephen (JIRA)
Julian Stephen created FLINK-9653: - Summary: Add operator name to latency metrics Key: FLINK-9653 URL: https://issues.apache.org/jira/browse/FLINK-9653 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-9652) Metrics for upstream and downstream

2018-06-24 Thread godfrey johnson (JIRA)
godfrey johnson created FLINK-9652: -- Summary: Metrics for upstream and downstream Key: FLINK-9652 URL: https://issues.apache.org/jira/browse/FLINK-9652 Project: Flink Issue Type: Task