[jira] [Created] (FLINK-22561) Restore checkpoint from another cluster

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

[jira] [Created] (FLINK-22561) Restore checkpoint from another cluster

Shang Yuanchun (Jira)
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)