[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367250#comment-17367250 ] Arvid Heise commented on FLINK-22698: - Merged into master as

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17353374#comment-17353374 ] Michał Ciesielczyk commented on FLINK-22698: [~austince] I think it's a good idea. If

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351899#comment-17351899 ] Austin Cawley-Edwards commented on FLINK-22698: --- [~nicholasjiang] – yes, I agree w/ Michał

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351619#comment-17351619 ] Michał Ciesielczyk commented on FLINK-22698: [~austince] In other data sources it's handled

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang commented on FLINK-22698: Thanks for [~cmick]'s investigation. The solution which

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350315#comment-17350315 ] Michał Ciesielczyk commented on FLINK-22698: Thanks. When the delivery times out, but the

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349300#comment-17349300 ] Austin Cawley-Edwards commented on FLINK-22698: --- Hi [~cmick] – that cause makes perfect

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17349245#comment-17349245 ] Michał Ciesielczyk commented on FLINK-22698: Hi [~austince], we've encountered a similar

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348011#comment-17348011 ] Nicholas Jiang commented on FLINK-22698: [~austince], thanks for tracking this issue. From this

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347771#comment-17347771 ] Austin Cawley-Edwards commented on FLINK-22698: --- Hey [~nicholasjiang] – I think that is

[jira] [Commented] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17347340#comment-17347340 ] Nicholas Jiang commented on FLINK-22698: [~austince], thank you for your research. From your