[ https://issues.apache.org/jira/browse/FLINK-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14569132#comment-14569132 ]
Robert Metzger commented on FLINK-2130: --------------------------------------- I would let the source fail. All the other components in Flink also always fail immediately. I guess there are ways to configure retries at the RabbitMQ connector. > RabbitMQ source does not fail when failing to retrieve elements > --------------------------------------------------------------- > > Key: FLINK-2130 > URL: https://issues.apache.org/jira/browse/FLINK-2130 > Project: Flink > Issue Type: Bug > Components: Streaming, Streaming Connectors > Reporter: Stephan Ewen > > The RMQ source only logs when elements cannot be retrieved. Failures are not > propagated. -- This message was sent by Atlassian JIRA (v6.3.4#6332)