Realtime Compute for Apache Flink:コネクタをローカルで実行およびデバッグする

ステップ 1: 依存関係を追加する

1. Maven 中央リポジトリからランタイムクラスを含むコネクタ uber JAR パッケージをダウンロードします。

   たとえば、MaxCompute コネクタの ververica-connector-odps 依存関係のバージョンが 1.17-vvr-8.0.11-1 の場合、Maven 中央リポジトリのディレクトリから ververica-connector-odps-1.17-vvr-8.0.11-1-uber.jar パッケージをオンプレミスのディレクトリにダウンロードする必要があります。

2. 実行環境を取得するときに、pipeline.classpaths パラメーターを uber JAR パッケージのパスに設定します。

   複数のコネクタ依存関係が存在する場合、パッケージのパスをセミコロン (;) で区切ります。たとえば、このパラメーターを file:///path/to/a-uber.jar;file:///path/to/b-uber.jar に設定できます。Windows では、file:///D:/path/to/a-uber.jar;file:///E:/path/to/b-uber/jar のように、関連するディスクの名前をパスに追加する必要があります。次のサンプルコードは、DataStream プログラムの構成を示しています。

   Configuration conf = new Configuration();
   conf.setString("pipeline.classpaths", "file://" + "uber JAR パッケージの絶対パス");
   StreamExecutionEnvironment env =
     	StreamExecutionEnvironment.getExecutionEnvironment(conf);

   次のサンプルコードは、Table API プログラムの構成を示しています。

   Configuration conf = new Configuration();
   conf.setString("pipeline.classpaths", "file://" + "uber JAR パッケージの絶対パス");
   EnvironmentSettings envSettings =
     	EnvironmentSettings.newInstance().withConfiguration(conf).build();
   TableEnvironment tEnv = TableEnvironment.create(envSettings);

ステップ 2: ジョブの実行に必要な ClassLoader JAR パッケージを構成する

Flink がコネクタのランタイムクラスをロードできるようにするには、ClassLoader JAR パッケージを構成に追加します。

1. VVR バージョンに基づいて ClassLoader JAR パッケージをダウンロードするには、クリックします。

   • VVR 6.x 用 ClassLoader JAR

   • VVR 8.x 用 ClassLoader JAR

   • VVR 11.x 用 ClassLoader JAR

2. IntelliJ IDEA でプログラムファイルを開きます。

3. エントリクラスの左側にある緑色のアイコンをクリックして、メニューを展開します。

   

4. [実行構成の変更...] を選択します。

   

5. 表示されたウィンドウで、[オプションの変更] をクリックします。

   

6. [実行オプションの追加] ドロップダウンリストの [java] セクションで、[クラスパスの変更] を選択します。

   [クラスパスの変更] セクションがウィンドウに表示されます。

7. [クラスパスの変更] セクションで、[+] アイコンをクリックし、[含める] を選択して、ダウンロードした ClassLoader JAR を選択します。

8. 構成を保存します。

   説明

   一般的な Flink クラスが見つからないことを示すエラーメッセージが表示された場合は、[オプションの変更] をクリックし、["provided" スコープで依存関係をクラスパスに追加する] を選択します。