Realtime Compute for Apache Flink:コネクタを含むジョブのローカルでの実行とデバッグ

ステップ1：ジョブ構成への依存関係の追加

まず、Maven Central Repository から、必要なランタイムクラスを含む uber JAR パッケージをダウンロードします。 たとえば、MaxCompute で使用される ververica-connector-odps 依存関係のバージョンが 1.17-vvr-8.0.11-1 の場合、Maven リポジトリの対応するディレクトリで -uber.jar サフィックスが付いた ververica-connector-odps-1.17-vvr-8.0.11-1-uber.jar ファイルを見つけ、ローカルディレクトリにダウンロードします。

コードで環境を作成する際に、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 API ジョブの場合は、次のコードを使用して構成を追加します。

Configuration conf = new Configuration();
conf.setString("pipeline.classpaths", "file://" + "absolute path of the uber jar");
StreamExecutionEnvironment env =
  	StreamExecutionEnvironment.getExecutionEnvironment(conf);

Table API ジョブの場合は、次のコードを使用して構成を追加します。

Configuration conf = new Configuration();
conf.setString("pipeline.classpaths", "file://" + "absolute path of the uber jar");
EnvironmentSettings envSettings =
  	EnvironmentSettings.newInstance().withConfiguration(conf).build();
TableEnvironment tEnv = TableEnvironment.create(envSettings);

ステップ2：ランタイムに必要な ClassLoader JAR パッケージの構成

Flink がコネクタのランタイムクラスをロードできるようにするには、ClassLoader JAR パッケージも追加する必要があります。まず、ご利用の Ververica Runtime (VVR) データベースエンジンのバージョンに基づいて、適切な ClassLoader JAR をダウンロードします。ダウンロードリンクは次のとおりです。

• VVR 6.x 用 ClassLoader JAR のダウンロード

• VVR 8.x 用 ClassLoader JAR のダウンロード

• VVR 11.x 用 ClassLoader JAR のダウンロード

例として、IntelliJ IDEA でジョブのローカル実行構成を変更します。エントリクラスの左側にある緑色のアイコンをクリックしてメニューバーを展開し、[実行構成の変更...] を選択します。

開いた実行構成ウィンドウで、[オプションの変更] をクリックし、[クラスパスの変更] を選択します。ウィンドウの下部に [クラスパスの変更] セクションが表示されます。`+` アイコンをクリックし、ダウンロードした ClassLoader JAR パッケージを選択して、実行構成を保存します。`org.apache.flink.configuration.Configuration` などの一般的な Flink クラスが見つからないというエラーメッセージが表示され、ジョブの実行に失敗した場合は、[オプションの変更] で [provided スコープの依存関係をクラスパスに追加] を選択します。

VVR 11.1 以降、VVR エンジンは JDK 11 を使用します。次の図に示すように、[JVM オプション] に `--add-opens java.base/jdk.internal.loader=ALL-UNNAMED` オプションを追加する必要があります。