Home / Flink

Apache Flink errors and exceptions

Common Apache Flink errors and exceptions with their exact messages, causes, ways to confirm them and fixes.

Checkpoints and state

• Flink: Checkpoint expired before completingA checkpoint did not finish within execution.checkpointing.timeout (10 minutes by default), so the JobManager aborted it. One expired checkpoint is harmless;…
• Flink: Exceeded checkpoint tolerable failure thresholdThe job failed because more checkpoints failed in a row than execution.checkpointing.tolerable-failed-checkpoints allows. The default is 0, so the first…

Resources and memory

• Flink: NoResourceAvailableException: Could not acquire the minimum required resourcesThe scheduler waited for task slots and gave up. The job needs more slots than the cluster can provide within slot.request.timeout (5 minutes by default),…

Network and heartbeats

• Flink: IllegalStateException: Buffer pool is destroyedA task tried to request a network buffer after its buffer pool was released, which happens while the task is being cancelled. This exception is almost always…
• Flink: The heartbeat of TaskManager with id ... timed outThe ResourceManager did not hear from a TaskManager within heartbeat.timeout (50 seconds by default) and released it, failing the tasks on it. The…

Connectors and classpath

• Flink SQL: Could not find any factory for identifier 'kafka'The 'connector' or 'format' option in a CREATE TABLE statement names a factory that is not on the classpath. Flink discovers connectors with Java SPI, so the…