2.2.4　編寫批處理代碼并測試執行

以2.2.1節所創建項目中的BatchJob源文件為模板，進一步編寫一個簡單的批處理代碼并執行。這里的目的是掌握如何使用IntelliJ IDEA創建Flink Maven項目，所以不必理解代碼，在后續的章節中會詳細講解。

在IntelliJ IDEA中打開BatchJob源文件，編輯代碼。

Scala代碼如下：

Java代碼如下：

在文件內任意空白處右擊，在彈出的快捷菜單中選擇run BatchJob，執行該程序，在下方的運行窗口可以看到輸出結果如下：

在執行此程序時，有可能會遇到異常信息，內容如下：

異常的原因是Maven引入依賴問題。打開項目中的pom.xml文件，將其中依賴部分的<scope>provided</scope>注釋（或刪除）掉，修改后的代碼如下：

另外，在IntelliJ IDEA中運行項目可能會導致Java.lang.NoClassDefFoundError異常。這可能是因為沒有將所有必需的Flink依賴項隱式地加載到類路徑中。

解決辦法是在IntelliJ IDEA中，選擇Run→Edit Configurations→Modify options，然后選擇include dependencies with＂Provided＂scope。這個運行配置現在將包括從IDE中運行應用程序所需的所有類。