[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2020-07-24 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164385#comment-17164385 ] Rafi Aroch commented on FLINK-11127: Data processing worked because the initiator of

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2020-07-24 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164373#comment-17164373 ] Rafi Aroch commented on FLINK-11127: [~rmetzger] At the time, I did not use K8S, I

[jira] [Created] (FLINK-17193) k8s-python-example build-example.sh improvements

2020-04-16 Thread Rafi Aroch (Jira)
Rafi Aroch created FLINK-17193: -- Summary: k8s-python-example build-example.sh improvements Key: FLINK-17193 URL: https://issues.apache.org/jira/browse/FLINK-17193 Project: Flink Issue Type: Impr

[jira] [Comment Edited] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-04-12 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17081922#comment-17081922 ] Rafi Aroch edited comment on FLINK-14881 at 4/12/20, 9:46 PM:

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-04-12 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17081922#comment-17081922 ] Rafi Aroch commented on FLINK-14881: I've updated the aws-sdk-version to: *1.11.754*

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-03-29 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070534#comment-17070534 ] Rafi Aroch commented on FLINK-14881: I looked into the testing aspect: Kinesis - Kin

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-02-24 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043275#comment-17043275 ] Rafi Aroch commented on FLINK-14881: [~trohrmann] This issue was opened under the Fi

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-02-17 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038842#comment-17038842 ] Rafi Aroch commented on FLINK-14881:  [~sewen] are there any concerns in adding this

[jira] [Updated] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-02-16 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafi Aroch updated FLINK-14881: --- Description: In order to use IAM Roles for Service Accounts in AWS EKS, the minimum required versio

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-02-12 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035982#comment-17035982 ] Rafi Aroch commented on FLINK-14881: Flink currently uses the Java SDK (Version 1) s

[jira] [Comment Edited] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-02-12 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035501#comment-17035501 ] Rafi Aroch edited comment on FLINK-14881 at 2/12/20 4:42 PM: -

[jira] [Commented] (FLINK-14881) Upgrade AWS SDK to support "IAM Roles for Service Accounts" in AWS EKS

2020-02-12 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035501#comment-17035501 ] Rafi Aroch commented on FLINK-14881: IAM Roles for Service Accounts have many advant

[jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter

2020-01-23 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022198#comment-17022198 ] Rafi Aroch commented on FLINK-7009: --- I developed similar functionality as a separate re

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

2019-11-03 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16965619#comment-16965619 ] Rafi Aroch commented on FLINK-11127: I'm seeing the same issue. We are not using Kub

[jira] [Commented] (FLINK-11333) First-class support for Protobuf types with evolvable schema

2019-08-22 Thread Rafi Aroch (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913266#comment-16913266 ] Rafi Aroch commented on FLINK-11333: Any plans to revive this task? Would be extreme

[jira] [Commented] (FLINK-10941) Slots prematurely released which still contain unconsumed data

2018-11-19 Thread Rafi Aroch (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692744#comment-16692744 ] Rafi Aroch commented on FLINK-10941: Saw same issue with Flink 1.5.4. Job fails with

[jira] [Assigned] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

2018-10-15 Thread Rafi Aroch (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafi Aroch reassigned FLINK-10525: -- Assignee: (was: Rafi Aroch) > Deserialization schema, skip data, that couldn't be properl

[jira] [Assigned] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized

2018-10-10 Thread Rafi Aroch (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rafi Aroch reassigned FLINK-10525: -- Assignee: Rafi Aroch > Deserialization schema, skip data, that couldn't be properly deseriali