[jira] [Comment Edited] (FLINK-16553) Missing KafkaFetcher topic/partition metrics

[ https://issues.apache.org/jira/browse/FLINK-16553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058893#comment-17058893 ] Tarush Grover edited comment on FLINK-16553 at 3/13/20, 4:24 PM: -

[jira] [Commented] (FLINK-16553) Missing KafkaFetcher topic/partition metrics

[ https://issues.apache.org/jira/browse/FLINK-16553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17058893#comment-17058893 ] Tarush Grover commented on FLINK-16553: --- [~aljoscha] I will come up with implement

[jira] [Commented] (FLINK-16528) Support Limit push down for streaming sources

[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057932#comment-17057932 ] Tarush Grover commented on FLINK-16528: --- [~jark] (y) > Support Limit push down fo

[jira] [Commented] (FLINK-16528) Support Limit push down for streaming sources

[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057908#comment-17057908 ] Tarush Grover commented on FLINK-16528: --- [~jark] Thanks! I will come up with desig

[jira] [Commented] (FLINK-16553) Missing KafkaFetcher topic/partition metrics

[ https://issues.apache.org/jira/browse/FLINK-16553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057896#comment-17057896 ] Tarush Grover commented on FLINK-16553: --- [~fabian.paul] Thanks! [~aljoscha] Can I

[jira] [Commented] (FLINK-16528) Support Limit push down for streaming sources

[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057840#comment-17057840 ] Tarush Grover commented on FLINK-16528: --- [~jark] +1, it makes sense to not use Top

[jira] [Commented] (FLINK-16553) Missing KafkaFetcher topic/partition metrics

[ https://issues.apache.org/jira/browse/FLINK-16553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057830#comment-17057830 ] Tarush Grover commented on FLINK-16553: --- [~fabian.paul] Can I take this issue? >

[jira] [Commented] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-16446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057829#comment-17057829 ] Tarush Grover commented on FLINK-16446: --- [~FrankZou] No problem, thanks :) > Add

[jira] [Commented] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-16446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057542#comment-17057542 ] Tarush Grover commented on FLINK-16446: --- [~FrankZou] Can I take this issue? > Add

[jira] [Comment Edited] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component

[ https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744746#comment-16744746 ] Tarush Grover edited comment on FLINK-10429 at 1/18/19 12:00 PM: -

[jira] [Comment Edited] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component

[ https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744746#comment-16744746 ] Tarush Grover edited comment on FLINK-10429 at 1/18/19 12:00 PM: -

[jira] [Commented] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745329#comment-16745329 ] Tarush Grover commented on FLINK-6626: -- [~till.rohrmann] Can I take this task? > Un

[jira] [Assigned] (FLINK-11382) Disable MetricFetcher if interval is configured to 0

[ https://issues.apache.org/jira/browse/FLINK-11382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tarush Grover reassigned FLINK-11382: - Assignee: (was: Tarush Grover) > Disable MetricFetcher if interval is configured to

[jira] [Assigned] (FLINK-11382) Disable MetricFetcher if interval is configured to 0

[ https://issues.apache.org/jira/browse/FLINK-11382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tarush Grover reassigned FLINK-11382: - Assignee: Tarush Grover > Disable MetricFetcher if interval is configured to 0 > --

[jira] [Commented] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component

[ https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744746#comment-16744746 ] Tarush Grover commented on FLINK-10429: --- Whats the current status for this ticket,

[jira] [Comment Edited] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461994#comment-16461994 ] Tarush Grover edited comment on FLINK-9178 at 5/3/18 6:31 AM: --

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461994#comment-16461994 ] Tarush Grover commented on FLINK-9178: -- [~tzulitai] Actually I had checked this `max.

[jira] [Commented] (FLINK-6420) Cleaner CEP API to specify conditions between events

[ https://issues.apache.org/jira/browse/FLINK-6420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16459591#comment-16459591 ] Tarush Grover commented on FLINK-6420: -- Can I take this up? > Cleaner CEP API to spe

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16456863#comment-16456863 ] Tarush Grover commented on FLINK-9178: -- [~fhueske] Thanks! Sure let me take the feedb

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16456112#comment-16456112 ] Tarush Grover commented on FLINK-9178: -- [~tzulitai] Please assign this task to me. >

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453832#comment-16453832 ] Tarush Grover commented on FLINK-9178: -- [~wind_ljy] One small question when we say ra

[jira] [Commented] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453585#comment-16453585 ] Tarush Grover commented on FLINK-9178: -- Can I take this task? I think Flink-5445 can