[jira] [Created] (FLINK-33131) Grafana dashboard for flink k8 operator metrics

Gaurav Miglani created FLINK-33131: -- Summary: Grafana dashboard for flink k8 operator metrics Key: FLINK-33131 URL: https://issues.apache.org/jira/browse/FLINK-33131 Project: Flink Issue

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758442#comment-17758442 ] Gaurav Miglani commented on FLINK-30843: yes we can close this now, I will pick it up later >

[jira] [Commented] (FLINK-31215) Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators

[ https://issues.apache.org/jira/browse/FLINK-31215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693946#comment-17693946 ] Gaurav Miglani commented on FLINK-31215: cool, earlier it was unassigned, that's why asked you,

[jira] [Commented] (FLINK-31215) Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators

[ https://issues.apache.org/jira/browse/FLINK-31215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17693923#comment-17693923 ] Gaurav Miglani commented on FLINK-31215: [~gyfora]   can you assigned it to me,  i want to work

[jira] [Commented] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686597#comment-17686597 ] Gaurav Miglani commented on FLINK-30920: [~mxm] [~gyfora] then do i have head's up to make

[jira] [Commented] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685390#comment-17685390 ] Gaurav Miglani commented on FLINK-30920: I think it is vertex id, as i can see in logs, [~mxm] 

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685055#comment-17685055 ] Gaurav Miglani commented on FLINK-30843: Ok, will do it and raise PR > Add Notifier For

[jira] [Commented] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17685052#comment-17685052 ] Gaurav Miglani commented on FLINK-30920: yes you are right, but in our cases, load came

[jira] [Updated] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Miglani updated FLINK-30920: --- Attachment: sample-logs > K8 cluster autoscaler | exclude operator ids from scaler >

[jira] [Updated] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Miglani updated FLINK-30920: --- Description: Sometime in cases of sink operator ids, where logic is heavy group aggregation

[jira] [Created] (FLINK-30920) K8 cluster autoscaler | exclude operator id from scaler

Gaurav Miglani created FLINK-30920: -- Summary: K8 cluster autoscaler | exclude operator id from scaler Key: FLINK-30920 URL: https://issues.apache.org/jira/browse/FLINK-30920 Project: Flink

[jira] [Updated] (FLINK-30920) K8 cluster autoscaler | exclude operator ids from scaler

[ https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Miglani updated FLINK-30920: --- Summary: K8 cluster autoscaler | exclude operator ids from scaler (was: K8 cluster

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684468#comment-17684468 ] Gaurav Miglani commented on FLINK-30843: [~gyfora]  waiting for your comment > Add Notifier For

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683789#comment-17683789 ] Gaurav Miglani commented on FLINK-30843: I think we can make it configurable via some config,

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17683768#comment-17683768 ] Gaurav Miglani commented on FLINK-30843: Hi [~gyfora]  waiting for your input, read

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682447#comment-17682447 ] Gaurav Miglani commented on FLINK-30843: I can start working on that if we want to add this

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682445#comment-17682445 ] Gaurav Miglani commented on FLINK-30843: Yes it makes sense, if you guys want, we can open

[jira] [Created] (FLINK-30843) Add Notifier For Autoscaler

Gaurav Miglani created FLINK-30843: -- Summary: Add Notifier For Autoscaler Key: FLINK-30843 URL: https://issues.apache.org/jira/browse/FLINK-30843 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-29165) Operator quickstart examples using code

[ https://issues.apache.org/jira/browse/FLINK-29165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17599525#comment-17599525 ] Gaurav Miglani commented on FLINK-29165: [~matyas]  can you please have a look into it >

[jira] [Updated] (FLINK-29165) Operator quickstart examples using code

[ https://issues.apache.org/jira/browse/FLINK-29165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Miglani updated FLINK-29165: --- Description: I will update doc(quick-start.md) and write code examples to create yaml and

[jira] [Comment Edited] (FLINK-29165) Operator quickstart examples using code

[ https://issues.apache.org/jira/browse/FLINK-29165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598770#comment-17598770 ] Gaurav Miglani edited comment on FLINK-29165 at 9/1/22 7:25 AM: can

[jira] [Commented] (FLINK-29165) Operator quickstart examples using code

[ https://issues.apache.org/jira/browse/FLINK-29165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17598770#comment-17598770 ] Gaurav Miglani commented on FLINK-29165: can anyone assigned it to me, raising PR > Operator

[jira] [Created] (FLINK-29165) Operator quickstart examples using code

Gaurav Miglani created FLINK-29165: -- Summary: Operator quickstart examples using code Key: FLINK-29165 URL: https://issues.apache.org/jira/browse/FLINK-29165 Project: Flink Issue Type:

[jira] [Created] (FLINK-25693) User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets

Gaurav Miglani created FLINK-25693: -- Summary: User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets Key: FLINK-25693 URL:

[jira] [Updated] (FLINK-25065) Update lookup document for jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Miglani updated FLINK-25065: --- Description: Update `lookup.cache.caching-missing-key` document for jdbc connector (was:

[jira] [Updated] (FLINK-25065) Update lookup document for jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Miglani updated FLINK-25065: --- Summary: Update lookup document for jdbc connector (was: Update lookup document for

[jira] [Created] (FLINK-25065) Update lookup document for mysql-connector

Gaurav Miglani created FLINK-25065: -- Summary: Update lookup document for mysql-connector Key: FLINK-25065 URL: https://issues.apache.org/jira/browse/FLINK-25065 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443330#comment-17443330 ] Gaurav Miglani commented on FLINK-24861: Hi [~wenlong.lwl] , [~MartijnVisser] , Any update here,

[jira] [Comment Edited] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442742#comment-17442742 ] Gaurav Miglani edited comment on FLINK-24861 at 11/12/21, 1:39 PM: --- Hi

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442742#comment-17442742 ] Gaurav Miglani commented on FLINK-24861: Hi [~wenlong.lwl] , Changes has been done, requesting

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442251#comment-17442251 ] Gaurav Miglani commented on FLINK-24861: Hi [~wenlong.lwl] , completely agree, extra option

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441749#comment-17441749 ] Gaurav Miglani commented on FLINK-24861: Hi [~MartijnVisser] , raised new PR:

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441740#comment-17441740 ] Gaurav Miglani commented on FLINK-24861: ya [~MartijnVisser]  working on it > Flink MySQL Look

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441684#comment-17441684 ] Gaurav Miglani commented on FLINK-24861: https://github.com/apache/flink/pull/17751 > Flink

[jira] [Created] (FLINK-24861) Flink MySQL Look cache update for empty hit

Gaurav Miglani created FLINK-24861: -- Summary: Flink MySQL Look cache update for empty hit Key: FLINK-24861 URL: https://issues.apache.org/jira/browse/FLINK-24861 Project: Flink Issue Type: