[FLINK-30417] RabbitMQ error is not clear

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.14.6
• Fix Version/s: rabbitmq-3.1.0
• Component/s: Connectors/ RabbitMQ
• Labels: pull-request-available
• Assignee: Yaron Shani
• Reporter: Yaron Shani
• Created: 14/Dec/22 13:01
• Updated: 12/Jan/24 08:50
• Resolved: 20/Dec/22 15:06

Description

Hey,

When there is no connection to the RabbitMQ flink prints:

java.lang.RuntimeException: Error while creating the channel

or

java.net.SocketTimeoutException: connect timeout

 

This is making very difficult for people to understand what exactly is failing. Is it the connection between the jobs/tasks manager? is it Kafka? Rabbit? something else?

I am going to make a PR that state that the error is the RabbitMQ connection.

Issue Links

• links to: GitHub Pull Request #4
• links to: GitHub Pull Request #21509