Coordinator unexpectedly terminated

[annurahar]

Created a iceberg sink connector with hourly partition and commit interval as 1 hour. At the time of commit, connector fails with below exception. This connector is working fine when commit interval is set to 15 mins.

Could someone please provide some insights ?

{
"name": "iceberg_lander",
"connector": {
"state": "RUNNING",
"worker_id": "10.7.213.7:8083"
},
"tasks": [
{
"id": 0,
"state": "FAILED",
"worker_id": "10.7.211.42:8083",
"trace": "org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception.\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:615)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:333)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:234)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:203)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:189)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:244)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)\n\tat java.base/java.lang.Thread.run(Thread.java:840)\nCaused by: io.tabular.iceberg.connect.channel.NotRunningException: Coordinator unexpectedly terminated\n\tat io.tabular.iceberg.connect.IcebergSinkTask.processControlEvents(IcebergSinkTask.java:168)\n\tat io.tabular.iceberg.connect.IcebergSinkTask.put(IcebergSinkTask.java:158)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:585)\n\t... 10 more\n"
}
],
"type": "sink"
}