zhang haoyan created FLINK-22561:
Summary: Restore checkpoint from another cluster
Key: FLINK-22561
URL: https://issues.apache.org/jira/browse/FLINK-22561
Project: Flink
Issue Type: Improvement
Environment: flink-1.12.1
hadoop 3.0.0-cdh6.3.2
Reporter: zhang haoyan
Hi, we have two hadoop clusters and run some flink streaming job on it
When we migrate some jobs from one cluster to another, we start the job just
like:
flink - s hdfs://clusterA/xx/xxx/chk-35 xxx.jar, but we will get an
error like 'java.io.FileNotFoundException: File does not exist:
/xxx/flink-checkpoints/cb46fc9afab25ced935e751dab49bee2/shared/329f6b79-292a-4d5d-b47b-a1cb63d02fe5',
it seems can't read shared path from another cluster
We don't want copy the share path manually every time and switch jobs between
this two cluster will be very often.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)