Hi Phil,
correction: But the error
you have is a familiar error if you have written some code to handle
directory path. --> But the error
you have is a familiar error if you have written some code to handle
directory path with Java.
No offence.
Best regards.
Jiadong. Lu
Jiadong Lu 于2024年5月20日周
Hi, Phil
I don't have more expertise about the flink-python module. But the error
you have is a familiar error if you have written some code to handle
directory path.
The correct form of Path/URI will be :
1. "/home/foo"
2. "file:///home/foo/boo"
3. "hdfs:///home/foo/boo"
4. or Win32 director
Hi Phil,
I think you can use the "-s :checkpointMetaDataPath" arg to resume the job
from a retained checkpoint[1].
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/checkpoints/#resuming-from-a-retained-checkpoint
Best,
Jinzhong Li
On Mon, May 20, 2024 at 2:29 AM Phil St
Hi Lu,
Thanks for your reply. In what way are the paths to get passed to the job that
needs to used the checkpoint? Is the standard way, using -s :/ or by
passing the path in the module as a Python arg?
Kind regards
Phil
> On 18 May 2024, at 03:19, jiadong.lu wrote:
>
> Hi Phil,
>
> AFAIK,
Hi Phil,
AFAIK, the error indicated your path was incorrect.
your should use '/opt/flink/checkpoints/1875588e19b1d8709ee62be1cdcc' or
'file:///opt/flink/checkpoints/1875588e19b1d8709ee62be1cdcc' instead.
Best.
Jiadong.Lu
On 5/18/24 2:37 AM, Phil Stavridis wrote:
Hi,
I am trying to test how
Hi Sandeep,
I think it should work fine with `StandaloneCompletedCheckpointStore`.
Have you checked if your directory /Users/test/savepoint is being
populated in the first place? And if so, if the restarted job is not
throwing some exceptions like it can not access those files?
Also note, that
