[Spark MicroBatchExecution] Error fetching kafka/checkpoint/state/0/0/1.delta does not exist

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[Spark MicroBatchExecution] Error fetching kafka/checkpoint/state/0/0/1.delta does not exist

Miguel Silvestre
Hi community,

I'm having this error in some kafka streams:

Caused by: java.io.FileNotFoundException: File file:/efs/.../kafka/checkpoint/state/0/0/1.delta does not exist

Because of this I have some streams down. How can I fix this?

Thank you.

--
Miguel Silvestre