Help Center/ Distributed Message Service for Kafka/ Troubleshooting/ Flink 1.15 Consumption Progress Submission Failure
Updated on 2024-11-20 GMT+08:00

Flink 1.15 Consumption Progress Submission Failure

Symptom

To consume Kafka messages in Flink 1.15, the consumption progress fails to be submitted, and the error messages "COORDINATOR_NOT_AVAILABLE" are thrown.

Root Cause

Bug on the Kafka client used by Flink 1.15: When the consumption progress fails to be submitted for once, the client sets the coordinator to unavailable and it cannot be automatically restored.

Solution

  • Restart the Flink job.
  • Upgrade Flink to 1.16 or later.