Hi Team,
We recently have started a use case where there would be involvement of
Kafka and Flink's low level APIs like map and process functions and since I
am entirely new to these stuffs, I couldn't get the exact approach/way to
test Kafka connector and low level APIs.
So can anyone share any w
Hi, Elakiya.
I think you could check :
1. The TaskManager Log to figure out whether the job is restoring from
an existing checkpoint and the restoring checkpoint path.
2. Or you could check the checkpoint ID when you restart your job (If
not restoring from a checkpoint, it starts from
Hi,
How did you point out the checkpoint path you restored from ?
Seems that you are trying to restore from a not completed or failed
checkpoint.
On Thu, Sep 28, 2023 at 6:09 PM rui chen wrote:
> When we use 1.13.2,we have the following error:
> FileNotFoundException: Cannot find metata file me
