[jira] [Commented] (FLINK-9311) PubSub connector

2018-05-07 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466409#comment-16466409 ] Richard Deurwaarder commented on FLINK-9311: PubSub works more like RabbitMQ than Kafka using

[jira] [Comment Edited] (FLINK-9311) PubSub connector

2018-05-07 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466409#comment-16466409 ] Richard Deurwaarder edited comment on FLINK-9311 at 5/7/18 8:06 PM:

[jira] [Created] (FLINK-9311) PubSub connector

2018-05-07 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-9311: -- Summary: PubSub connector Key: FLINK-9311 URL: https://issues.apache.org/jira/browse/FLINK-9311 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-28 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632161#comment-16632161 ] Richard Deurwaarder commented on FLINK-10419: - I have actually run into a very similar

[jira] [Commented] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

2019-04-02 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16807578#comment-16807578 ] Richard Deurwaarder commented on FLINK-12075: - I've just tested the PR of [~till.rohrmann] 

[jira] [Created] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

2019-04-01 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-12075: --- Summary: Not able to submit jobs on YARN when there's a firewall Key: FLINK-12075 URL: https://issues.apache.org/jira/browse/FLINK-12075 Project: Flink

[jira] [Updated] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

2019-04-01 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder updated FLINK-12075: Description: If there is a firewall around the YARN cluster and the machine,

[jira] [Assigned] (FLINK-12376) GCS runtime exn: Request payload size exceeds the limit

2019-05-08 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder reassigned FLINK-12376: --- Assignee: Richard Deurwaarder > GCS runtime exn: Request payload size

[jira] [Comment Edited] (FLINK-12376) GCS runtime exn: Request payload size exceeds the limit

2019-05-08 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835427#comment-16835427 ] Richard Deurwaarder edited comment on FLINK-12376 at 5/8/19 8:37 AM: -

[jira] [Comment Edited] (FLINK-12376) GCS runtime exn: Request payload size exceeds the limit

2019-05-08 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835427#comment-16835427 ] Richard Deurwaarder edited comment on FLINK-12376 at 5/8/19 8:37 AM: -

[jira] [Commented] (FLINK-12376) GCS runtime exn: Request payload size exceeds the limit

2019-05-08 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835427#comment-16835427 ] Richard Deurwaarder commented on FLINK-12376: - [~StephanEwen] PubSub has no concept of

[jira] [Updated] (FLINK-13083) Various improvements PubSub Connector

2019-07-04 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder updated FLINK-13083: Description: * Add retry mechanism to Acknowledgement calls * Replace

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

2019-07-11 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883051#comment-16883051 ] Richard Deurwaarder commented on FLINK-13083: - Hi [~becket_qin], I have not yet, except for

[jira] [Created] (FLINK-13231) Add a ratelimiter to pubsub source

2019-07-11 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-13231: --- Summary: Add a ratelimiter to pubsub source Key: FLINK-13231 URL: https://issues.apache.org/jira/browse/FLINK-13231 Project: Flink Issue Type:

[jira] [Updated] (FLINK-13083) Various improvements PubSub Connector

2019-07-11 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder updated FLINK-13083: Description: Umbrella task to keep track of issues remaining when FLINK-9311 was

[jira] [Created] (FLINK-13230) Retry acknowledgement calls

2019-07-11 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-13230: --- Summary: Retry acknowledgement calls Key: FLINK-13230 URL: https://issues.apache.org/jira/browse/FLINK-13230 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13231) Add a ratelimiter to pubsub source

2019-07-12 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883594#comment-16883594 ] Richard Deurwaarder commented on FLINK-13231: - [~becket_qin] I was looking into this, the

[jira] [Updated] (FLINK-13133) Correct error in PubSub documentation

2019-07-07 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder updated FLINK-13133: Component/s: Connectors / Google Cloud PubSub > Correct error in PubSub

[jira] [Created] (FLINK-13133) Correct error in PubSub documentation

2019-07-07 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-13133: --- Summary: Correct error in PubSub documentation Key: FLINK-13133 URL: https://issues.apache.org/jira/browse/FLINK-13133 Project: Flink Issue

[jira] [Created] (FLINK-13083) Various improvements PubSub Connector

2019-07-03 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-13083: --- Summary: Various improvements PubSub Connector Key: FLINK-13083 URL: https://issues.apache.org/jira/browse/FLINK-13083 Project: Flink Issue

[jira] [Assigned] (FLINK-13083) Various improvements PubSub Connector

2019-07-03 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder reassigned FLINK-13083: --- Assignee: Richard Deurwaarder > Various improvements PubSub Connector >

[jira] [Created] (FLINK-12325) Statsd reporter gives wrong metrics when using negative numbers

2019-04-24 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-12325: --- Summary: Statsd reporter gives wrong metrics when using negative numbers Key: FLINK-12325 URL: https://issues.apache.org/jira/browse/FLINK-12325

[jira] [Updated] (FLINK-12325) Statsd reporter gives wrong metrics when using negative numbers

2019-04-24 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder updated FLINK-12325: Description: The statsd reporter has a bug I believe when using negative numbers.

[jira] [Updated] (FLINK-12325) Statsd reporter gives wrong metrics when using negative numbers

2019-04-24 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Deurwaarder updated FLINK-12325: Description: The statsd reporter has a bug I believe when using negative numbers.

[jira] [Created] (FLINK-13700) PubSub connector example not included in flink-dist

2019-08-13 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-13700: --- Summary: PubSub connector example not included in flink-dist Key: FLINK-13700 URL: https://issues.apache.org/jira/browse/FLINK-13700 Project: Flink

[jira] [Commented] (FLINK-13306) flink-examples-streaming-gcp-pubsub is missing NOTICE

2019-08-13 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905976#comment-16905976 ] Richard Deurwaarder commented on FLINK-13306: - I had not seen this discussion before

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

2019-08-07 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16902456#comment-16902456 ] Richard Deurwaarder commented on FLINK-13083: - Hi [~becket_qin], apologies for the late

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

2019-08-08 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16902969#comment-16902969 ] Richard Deurwaarder commented on FLINK-13083: - I've just ran out integration tests and ran

[jira] [Comment Edited] (FLINK-13083) Various improvements PubSub Connector

2019-08-08 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16902969#comment-16902969 ] Richard Deurwaarder edited comment on FLINK-13083 at 8/8/19 1:22 PM: -

[jira] [Commented] (FLINK-10428) AbstractServerBase should bind to any address per default

2019-07-18 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887843#comment-16887843 ] Richard Deurwaarder commented on FLINK-10428: - [~yanghua] did you have a chance to look at

[jira] [Commented] (FLINK-13230) Retry acknowledgement calls

2019-09-29 Thread Richard Deurwaarder (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940490#comment-16940490 ] Richard Deurwaarder commented on FLINK-13230: - [~jark] would it instead be possible to merge

[jira] [Commented] (FLINK-12751) Create file based HA support

2019-06-27 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873907#comment-16873907 ] Richard Deurwaarder commented on FLINK-12751: - I am not sure if kubelet controls this, nor