Robert Metzger created FLINK-4051: ------------------------------------- Summary: RabbitMQ Source might not react to cancel signal Key: FLINK-4051 URL: https://issues.apache.org/jira/browse/FLINK-4051 Project: Flink Issue Type: Bug Components: Streaming Connectors Reporter: Robert Metzger
As reported here https://issues.apache.org/jira/browse/FLINK-3763?focusedCommentId=15322517&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-15322517, the RabbitMQ source might block forever / ignore the cancelling signal, if its listening to an empty queue. Fix: call nextDelivery() with a timeout. -- This message was sent by Atlassian JIRA (v6.3.4#6332)