[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-12 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134241#comment-17134241 ] Austin Cawley-Edwards commented on FLINK-10195: --- [~aljoscha] that would be great, thank

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-12 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134180#comment-17134180 ] Aljoscha Krettek commented on FLINK-10195: -- [~austince] should I assign the issue to you? >

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-03 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125362#comment-17125362 ] Austin Cawley-Edwards commented on FLINK-10195: --- Yes, that is correct, though I think it

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-03 Thread Luka Jurukovski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125225#comment-17125225 ] Luka Jurukovski commented on FLINK-10195: - [~austince] Your example did inform me to a feature

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-01 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121227#comment-17121227 ] Austin Cawley-Edwards commented on FLINK-10195: --- Hey all, just bringing this back up as

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2018-08-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16594098#comment-16594098 ] Stephan Ewen commented on FLINK-10195: -- You can assign the issue to yourself, once we add you to

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2018-08-27 Thread Luka Jurukovski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16593585#comment-16593585 ] Luka Jurukovski commented on FLINK-10195: - Just tested using the "basicGet" and a buffer. It

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2018-08-25 Thread Luka Jurukovski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592649#comment-16592649 ] Luka Jurukovski commented on FLINK-10195: - The option that you describe is the what my ugly code

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2018-08-25 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592595#comment-16592595 ] Stephan Ewen commented on FLINK-10195: -- Thanks for the input. This seems to be a fundamental issue

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2018-08-24 Thread Luka Jurukovski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592182#comment-16592182 ] Luka Jurukovski commented on FLINK-10195: - [~StephanEwen] For what I can tell no. Although this

[jira] [Commented] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2018-08-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590591#comment-16590591 ] Stephan Ewen commented on FLINK-10195: -- Is that something that can be configured on RabbitMQ, for