Developing an MRS Flink Job¶

This section describes how to develop an MRS Flink job on DataArts Factory. Use an MRS Flink job to count the number of words.

Prerequisites¶

Upload the job resource package and data file to the OBS bucket.
Note
In this example, upload WordCount.jar to lkj_test/WordCount.jar and word.txt to lkj_test/input/word.txt.
Create an empty job named job_MRS_Flink.
Figure 1 Creating a job¶
Go to the job development page, drag the MRS Flink node to the canvas, and click the node to configure its properties.
Figure 2 Configuring properties for an MRS Flink node¶
Parameter descriptions:
```
--Flink job name
wordcount
--MRS cluster name
Select an MRS cluster.
--Program parameter
-c    org.apache.flink.streaming.examples.wordcount.WordCount
--Flink job resource package
wordcount
--Input data path
obs://dlf-beijing2/lkj_test/input/word.txt
--Output data path
obs://dlf-beijing2/lkj_test/output.txt
```
Specifically:
obs://dlf-beijing2/lkj_test/input/word.txt is the directory where the wordcount.jar parameters are passed. You can pass the words to count.
obs://dlf-beijing2/lkj_test/output.txt is the directory where the output parameter file is stored. (If the output.txt file already exists, an error is reported.)
Click Test to execute the MRS Flink job.
After the test is complete, click Submit.
Choose Monitor Job in the navigation pane and view the job execution result.
View the returned records in the OBS bucket. (Skip this step if the return function is not configured.)

last updated: 2025-07-09 14:35 UTC - commit: d615b325251d87083330e48e30efad3971e0fa88