Verifying the Consistency of Data Migrated from Delta Lake (without Metadata) to MRS Delta Lake

Preparations

Install the MgC Agent, an MgC tool used for data verification, in the source intranet environment and register an account for using the MgC Agent. For details, see Installing the MgC Agent for Linux.

Procedure

1. Sign in to the MgC console.
2. In the navigation pane on the left, choose Settings.
3. Under Migration Projects, click Create Project.
   Figure 1 Creating a project
   

4. Set Project Type to Complex migration (for big data), enter a project name, and click Create.
   Figure 2 Creating a big data migration project
   

5. Connect the MgC Agent to MgC. For more information, see Connecting the MgC Agent to MgC.
6. After the connection is successful, add the username/password pairs for accessing the source Delta Lake executor and the target MRS Delta Lake executor to the MgC Agent. For more information, see Adding Resource Credentials.

   

7. In the navigation pane, choose Migrate > Big Data Verification. In the navigation pane, under Project, select the project created in step 4.
8. If you are performing a big data verification with MgC for the first time, select your MgC Agent to enable this feature. Click Select MgC Agent. In the displayed dialog box, select the MgC Agent you connected to MgC from the drop-down list.
   

   Ensure that the selected MgC Agent is always Online and Enabled before your verification is complete.

9. In the Features area, click Preparations.
10. Choose Connection Management and click Create Connection.
    Figure 3 Creating a connection
    

11. Select Delta Lake (without metadata) and click Next.

    

12. Set connection parameters based on Table 1 and click Test. If the test is successful, the connection is set up.

    Table 1 Parameters for creating a connection to Delta Lake (without metadata)

    Parameter	Configuration
    Connection To	Select Source.
    Connection Name	The default name is Delta-Lake-without-metadata-4 random characters (including letters and numbers). You can also customize a name.
    MgC Agent	Select the MgC Agent connected to MgC in step 5.
    Executor Credential	Select the source Delta Lake executor credential added to the MgC Agent in step 5.
    Executor IP Address	Enter the IP address for connecting to the executor.
    Executor Port	Enter the port for connecting to the executor. The default port is 22.
    Spark Client Directory	Enter the absolute path of the bin directory on the Spark client.
    Environment Variable Address	Enter the absolute path of the environment variable file, for example, /opt/bigdata/client/bigdata_env. If this field is not left blank, the environment variable file is automatically sourced before commands are executed.
    SQL File Location	Enter a directory for storing the SQL files generated for consistency verification. You must have the read and write permissions for the folder. NOTICE: After the migration is complete, you need to manually clear the folders generated at this location to release storage space.
    Collect Usage Metrics	This parameter is optional. If this option is enabled, usage metrics for your big data resources will be collected during the execution of tasks created using this connection. The collected information is used to generate reports on the MgC console and for performance optimization. NOTICE: Before using this function, ensure that the Huawei Cloud account you added to the MgC Agent has the read-only permission for MRS and DLI. If the selected credential is the one you currently use to access MgC, you can select This is my MgC credential, and the projects in the region you choose will be listed. Under Region, select the region where the data to be verified is located. Under Project, select the project where the data to be verified is stored. Under Cluster ID, enter the ID of the cluster where the data to be verified is located. If the selected Doris credential is not the one you currently use to access MgC: Under Region ID, enter the ID of the region where the data to be verified is located. For example, if the region is CN South-Guangzhou, enter cn-south-1. Under Project ID, enter the project ID corresponding to the region. Under Cluster ID, enter the ID of the cluster where the data to be verified is located. NOTE: To view the region ID and project ID, choose My Credentials > API Credentials. For details about how to obtain the cluster ID, see Obtaining an MRS Cluster ID.

13. After the connection test is successful, click Confirm. The cloud service connection is set up.
14. Choose Metadata Management and click the Tables tab.

    

15. On the displayed page, click Import.

    

16. Click Download to download the import template to the local PC. Open the template, fill in table information, and save the template.
17. In the Import Tables dialog box, click Select File, choose the filled template file, and click Confirm. After the import is complete, you can view the imported tables on Tables tab.

    

18. In the Features area, click Table Management.
19. Under Table Groups, click Create. Configure the parameters for creating a table group and click Confirm.

    

    Table 2 Parameters for creating a table group

    Parameter	Description
    Table Group	Enter a name.
    Metadata Source	Select the connection created in step 12. CAUTION: A table group can only contain tables coming from the same metadata source.
    Verification Rule	Select a rule that defines the method for verifying data consistency and the inconsistency tolerance. MgC provides multiple verification rules for you to choose. For details about these rules, click View More.
    Description (Optional)	Enter a description to identify the table group.

20. On the Table Management page, click the Tables tab, select the data tables to be added to the same table group, and choose Option > Add Tables to Group above the list. In the displayed dialog box, select the desired table group and click Confirm.

    

    

    You can manually import information of incremental data tables to MgC. For details, see Creating a Table Group and Adding Tables to the Group.

21. Create a connection to the source and target executors separately. For details, see Creating an Executor Connection. Select the source and target executor credentials added to the MgC Agent in step 6.
22. Create a data verification task for the source and target Delta Lake clusters, respectively, and execute the tasks. For more information, see Creating and Executing Verification Tasks. During the task creation, select the table group created in step 19.
    • On the Select Task Type page, choose Delta Lake.

      

    • Select a verification method. For details about each verification method, see Verification Methods.

23. Wait until the task executions enter a Completed status. You can view and export the task execution results on the Verification Results page. For details, see Viewing and Exporting Verification Results.