Updated on 2023-04-28 GMT+08:00

Viewing Commissioning Results

  1. Check whether the job is executed.
    • Using the Flink web UI

      If a success message is returned on the Flink web UI, the execution is successful. You can choose More > Job Monitoring in the Operation column to view detailed logs.

    • Using the Flink client

      Log in to FusionInsight Manager as a running user, go to the native page of the Yarn service, find the application of the corresponding job, and click the application name to go to the job details page.

      • If the job is not complete, click Tracking URL to go to the native Flink service page and view the job running information.
      • If the job submitted in a session has been completed, you can click Tracking URL to log in to the native Flink service page to view job information.

  2. Verify the job execution result.
    • FlinkIoTDBSink execution result:
      • Run the following command on the IoTDB client and check whether the data has been written from Flink to IoTDB:

        select * from root.sg.d1

      • FlinkIoTDBSource execution result:
        1. Log in to FusionInsight Manager as a running user and choose Cluster > Services > HDFS. Click the hyperlink next to NameNode WebUI to access the HDFS web UI.
        2. Choose Utilities > Browse the file system.

        3. Go to the /tmp/logs/Execution username/bucket-logs-tfile/Task ID/Flink task ID directory and download all files in the directory to the local PC.

        4. Search for root.sg.d1 in the files downloaded in 2.c. If the following information is displayed, data is successfully read from IoTDB.