Step 1: Migrate Service Data
You can design a migration solution based on your scenarios and the reliability mechanism for Flink jobs. CS and DLI both support a service migration solution based on Flink savepoints. Flink jobs that comply with this solution can be migrated using savepoints.
Before service migration, verify that a DLI job is running properly.
Procedure
- Stop a CS job and obtain the job savepoint.
On the Job Management page of the CS console, locate the target job and click Stop in the Operation column. On the displayed dialog box, enable Trigger Savepoint and click Yes to stop the job and obtain the current savepoint of the job.
Figure 1 Obtaining a savepoint
When stopping a job, ensure that Trigger Savepoint is enabled. By default, savepoints are not triggered.
- Export the job savepoint.
On the Job Management page of the CS console, locate the target job and choose More > Export Savepoint in the Operation column to export the job savepoint to the specified OBS path.
Figure 2 Export the savepoint
- Import the savepoint to DLI.
On the Job Management page of the DLI console, locate the target job and choose More > Import to Savepoint in the Operation column to import the job savepoint exported in 2.
Figure 3 Importing the savepoint
- Restore the job from the savepoint.
On the Job Management page of the DLI console, select the target job and click Start. On the Start Job page, select Restore Savepoint to restore the job from the savepoint. If the savepoint has been imported but this button is unavailable, refresh the job list.
Figure 4 Restoring the job from the savepoint
When starting a job, ensure that Restore Savepoint is selected. By default, the job is not restored from the savepoint.
Last Article: Risks and Countermeasures
Next Article: Step 2: Verify Functions
Did this article solve your problem?
Thank you for your score！Your feedback would help us improve the website.