[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17116530#comment-17116530 ] Richard Deurwaarder commented on FLINK-16572: - Could it be that this was run

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114716#comment-17114716 ] Richard Deurwaarder commented on FLINK-16572: - Apologies for the delay [~rme

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17101614#comment-17101614 ] Richard Deurwaarder commented on FLINK-16572: - Yeah I'll have another look,

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076169#comment-17076169 ] Richard Deurwaarder commented on FLINK-16572: - Sure, I'll have a look at it

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17051013#comment-17051013 ] Richard Deurwaarder commented on FLINK-16142: - [~sewen] you mention this: {n

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

[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940490#comment-16940490 ] Richard Deurwaarder commented on FLINK-13230: - [~jark] would it instead be p

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

[ https://issues.apache.org/jira/browse/FLINK-13306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16905976#comment-16905976 ] Richard Deurwaarder commented on FLINK-13306: - I had not seen this discussio

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

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-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902969#comment-16902969 ] Richard Deurwaarder commented on FLINK-13083: - I've just ran out integration

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16902456#comment-16902456 ] Richard Deurwaarder commented on FLINK-13083: - Hi [~becket_qin], apologies f

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

[ https://issues.apache.org/jira/browse/FLINK-10428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887843#comment-16887843 ] Richard Deurwaarder commented on FLINK-10428: - [~yanghua] did you have a cha

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

[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883594#comment-16883594 ] Richard Deurwaarder commented on FLINK-13231: - [~becket_qin] I was looking i

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

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883051#comment-16883051 ] Richard Deurwaarder commented on FLINK-13083: - Hi [~becket_qin], I have not

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

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

[ 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 m

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

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: Sub-tas

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

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 Typ

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

[ 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 documentat

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

[ 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 MaxMessages

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

[ 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-13083) Various improvements PubSub Connector

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 Typ

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

[ https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873907#comment-16873907 ] Richard Deurwaarder commented on FLINK-12751: - I am not sure if kubelet cont

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

[ https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835427#comment-16835427 ] Richard Deurwaarder commented on FLINK-12376: - [~StephanEwen] PubSub has no

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

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

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

[ 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 excee

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

[ 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-12325) Statsd reporter gives wrong metrics when using negative numbers

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 Project

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

[ 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] [Commented] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

[ https://issues.apache.org/jira/browse/FLINK-12075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807578#comment-16807578 ] Richard Deurwaarder commented on FLINK-12075: - I've just tested the PR of [~

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

[ 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, submi

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

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] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16632161#comment-16632161 ] Richard Deurwaarder commented on FLINK-10419: - I have actually run into a ve

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466409#comment-16466409 ] Richard Deurwaarder commented on FLINK-9311: PubSub works more like RabbitMQ t

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

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