[DISCUSSION] Kafka Metrics Reporter

2019-11-17 Thread Gyula Fóra
Hi all! Several users have asked in the past about a Kafka based metrics reporter which can serve as a natural connector between arbitrary metric storage systems and a straightforward way to process Flink metrics downstream. I think this would be an extremely useful addition but I would like to h

[jira] [Created] (FLINK-14833) Remove unnecessary SnapshotStrategySynchronicityBehavior from HeapSnapshotStrategy

2019-11-17 Thread Jiayi Liao (Jira)
Jiayi Liao created FLINK-14833: -- Summary: Remove unnecessary SnapshotStrategySynchronicityBehavior from HeapSnapshotStrategy Key: FLINK-14833 URL: https://issues.apache.org/jira/browse/FLINK-14833 Projec

[jira] [Created] (FLINK-14834) Running Kerberized YARN on Docker test (custom fs plugin) fails on Travis

2019-11-17 Thread Gary Yao (Jira)
Gary Yao created FLINK-14834: Summary: Running Kerberized YARN on Docker test (custom fs plugin) fails on Travis Key: FLINK-14834 URL: https://issues.apache.org/jira/browse/FLINK-14834 Project: Flink

Re: [DISCUSSION] Kafka Metrics Reporter

2019-11-17 Thread Konstantin Knauf
Hi Gyula, thank you for proposing this. +1 for adding a KafkaMetricsReporter. In terms of the dependency we could go a similar route as for the "universal" Flink Kafka Connector which to my knowledge always tracks the latest Kafka version as of the Flink release and relies on compatibility of the

Weekly Community Update 2019/46

2019-11-17 Thread Konstantin Knauf
Dear community, happy to share this week's community update. While slowly approaching the planned feature freeze for Flink 1.10, things have calmed down a bit on the dev mailing list. Stil there are couple of interesting topics to cover. This week's digest includes an update on the Flink 1.8.3 rel

Re: [DISCUSSION] Kafka Metrics Reporter

2019-11-17 Thread Becket Qin
Hi Gyula, Thanks for bringing this up. It is a useful addition to have a Kafka metrics reporter. I understand that we already have Prometheus and DataDog reporters in the Flink main repo. However, personally speaking, I would slightly prefer to have the Kafka metrics reporter as an ecosystem proje

[jira] [Created] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

2019-11-17 Thread Victor Wong (Jira)
Victor Wong created FLINK-14835: --- Summary: Make `org.apache.flink.configuration.Configuration` support method chaining Key: FLINK-14835 URL: https://issues.apache.org/jira/browse/FLINK-14835 Project: Fl

Re: [VOTE] FLIP-83: Flink End-to-end Performance Testing Framework

2019-11-17 Thread aihua li
+1 (non-binding) Thanks Yu Li for driving on this. > 在 2019年11月15日，下午8:10，Yu Li 写道： > > Hi All, > > I would like to start the vote for FLIP-83 [1] which is discussed and > reached consensus in the discussion thread [2]. > > The vote will be open for at least 72 hours (excluding weekend). I'

Re: [VOTE] FLIP-83: Flink End-to-end Performance Testing Framework

2019-11-17 Thread OpenInx
+1 (non-binding) On Mon, Nov 18, 2019 at 11:54 AM aihua li wrote: > +1 (non-binding) > > Thanks Yu Li for driving on this. > > > 在 2019年11月15日，下午8:10，Yu Li 写道： > > > > Hi All, > > > > I would like to start the vote for FLIP-83 [1] which is discussed and > > reached consensus in the discussion

Re: [VOTE] FLIP-83: Flink End-to-end Performance Testing Framework

2019-11-17 Thread jincheng sun
+1 (binding) OpenInx 于2019年11月18日周一 下午12:09写道： > +1 (non-binding) > > On Mon, Nov 18, 2019 at 11:54 AM aihua li wrote: > > > +1 (non-binding) > > > > Thanks Yu Li for driving on this. > > > > > 在 2019年11月15日，下午8:10，Yu Li 写道： > > > > > > Hi All, > > > > > > I would like to start the vote for