[jira] [Comment Edited] (FLINK-14316) stuck in "Job leader ... lost leadership" error

[ https://issues.apache.org/jira/browse/FLINK-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946580#comment-16946580 ] Piyush Goyal edited comment on FLINK-14316 at 10/9/19 7:02 PM: ---

[jira] [Comment Edited] (FLINK-14316) stuck in "Job leader ... lost leadership" error

[ https://issues.apache.org/jira/browse/FLINK-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946580#comment-16946580 ] Piyush Goyal edited comment on FLINK-14316 at 10/9/19 7:01 PM: ---

[jira] [Commented] (FLINK-14316) stuck in "Job leader ... lost leadership" error

[ https://issues.apache.org/jira/browse/FLINK-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946580#comment-16946580 ] Piyush Goyal commented on FLINK-14316: -- Added the patch that seemed to help.  > st

[jira] [Updated] (FLINK-14316) stuck in "Job leader ... lost leadership" error

[ https://issues.apache.org/jira/browse/FLINK-14316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-14316: - Attachment: RpcConnection.patch > stuck in "Job leader ... lost leadership" error >

[jira] [Commented] (FLINK-12423) Add Timer metric type for flink-metrics module

[ https://issues.apache.org/jira/browse/FLINK-12423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860215#comment-16860215 ] Piyush Goyal commented on FLINK-12423: -- At Netflix, we use Atlas([https://github.co

[jira] [Commented] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860210#comment-16860210 ] Piyush Goyal commented on FLINK-12680: -- [~till.rohrmann] A good way to look at it i

[jira] [Comment Edited] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16854176#comment-16854176 ] Piyush Goyal edited comment on FLINK-12680 at 6/3/19 3:00 AM:

[jira] [Comment Edited] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16854176#comment-16854176 ] Piyush Goyal edited comment on FLINK-12680 at 6/3/19 3:00 AM:

[jira] [Commented] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16854176#comment-16854176 ] Piyush Goyal commented on FLINK-12680: -- thanks [~yanghua] ! If you haven't started

[jira] [Updated] (FLINK-12681) Provide an implementation of a thread-safe counter

[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12681: - Description: While adding metrics to Elasticsearch connector, we noticed that the SimpleCounter

[jira] [Commented] (FLINK-12681) Make SimpleCounter thread-safe.

[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851815#comment-16851815 ] Piyush Goyal commented on FLINK-12681: -- thanks [~SleePy] ! yes we can leave Simple

[jira] [Updated] (FLINK-12681) Provide an implementation of a thread-safe counter

[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12681: - Description: While adding metrics to Elasticsearch connector, we noticed that the SimpleCounter

[jira] [Updated] (FLINK-12681) Make SimpleCounter thread-safe.

[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12681: - Description: While adding metrics to Elasticsearch connector, we noticed that the SimpleCounter

[jira] [Updated] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12680: - Description: Currently Flink metric system supports counter, gauge, histogram and meter. For ca

[jira] [Updated] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12680: - Description: Currently Flink metric system supports counter, gauge, histogram and meter. For ca

[jira] [Updated] (FLINK-12681) Make SimpleCounter thread-safe.

[ https://issues.apache.org/jira/browse/FLINK-12681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12681: - Description: While adding metrics to Elasticsearch connector we noticed that the SimpleCounter

[jira] [Created] (FLINK-12681) Make SimpleCounter thread-safe.

Piyush Goyal created FLINK-12681: Summary: Make SimpleCounter thread-safe. Key: FLINK-12681 URL: https://issues.apache.org/jira/browse/FLINK-12681 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12680: - Description: Currently Flink metric system supports counter, gauge, histogram and meter. For ca

[jira] [Updated] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12680: - Description: Currently Flink metric system supports counter, gauge, histogram and meter. For ca

[jira] [Updated] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12680: - Description: Currently Flink metric system supports counter, gauge, histogram and meter. For ca

[jira] [Updated] (FLINK-12680) Add timer type to metric system

[ https://issues.apache.org/jira/browse/FLINK-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piyush Goyal updated FLINK-12680: - Description: Currently Flink metric system supports counter, gauge, histogram and meter. For ca

[jira] [Created] (FLINK-12680) Add timer type to metric system

Piyush Goyal created FLINK-12680: Summary: Add timer type to metric system Key: FLINK-12680 URL: https://issues.apache.org/jira/browse/FLINK-12680 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837512#comment-16837512 ] Piyush Goyal edited comment on FLINK-7697 at 5/14/19 7:01 PM: -

[jira] [Comment Edited] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837512#comment-16837512 ] Piyush Goyal edited comment on FLINK-7697 at 5/14/19 7:00 PM: -

[jira] [Commented] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837512#comment-16837512 ] Piyush Goyal commented on FLINK-7697: - +1 on adding metrics to ES Sink.  Few others