Realtime Compute for Apache Flink:Flink Agents の開発 (ベータ)

Python ジョブ

次のファイルを含む quickstart-python.zip をダウンロードします：

ダウンロードした ZIP パッケージは、解凍せずにそのままアップロードできます。この例で使用する openai や dashscope などの Python 依存関係は、VVR エンジンイメージに事前インストールされています。

Java ジョブ

次のファイルをダウンロードします：

Python ジョブの構成

Java ジョブの構成

ランタイムパラメータ

[Deployment Details > Runtime parameter configuration > Edit > Other Configurations] に移動し、Flink の構成項目を追加します。

• Python ジョブ

  python.executable: python3.10
  python.client.executable: python3.10
  containerized.master.env.FLINK_HOME: /flink
  containerized.taskmanager.env.FLINK_HOME: /flink
  classloader.parent-first-patterns.default: java.;scala.;com.esotericsoftware.kryo;org.apache.hadoop.;javax.annotation.;org.xml;javax.xml;org.apache.xerces;org.w3c;org.rocksdb.;org.slf4j;org.apache.log4j;org.apache.logging;org.apache.commons.logging;ch.qos.logback

• Java ジョブ

  classloader.parent-first-patterns.default: java.;scala.;com.esotericsoftware.kryo;org.apache.hadoop.;javax.annotation.;org.xml;javax.xml;org.apache.xerces;org.w3c;org.rocksdb.;org.slf4j;org.apache.log4j;org.apache.logging;org.apache.commons.logging;ch.qos.logback

  パラメータの説明

  パラメータ	説明
  python.executable / python.client.executable	Python インタプリタのバージョンを指定します (Python ジョブのみ)。
  containerized.{master,taskmanager}.env.FLINK_HOME	JobManager と TaskManager の FLINK_HOME 環境変数を設定します (Python ジョブのみ)。
  classloader.parent-first-patterns.default	親 ClassLoader から優先的にロードされるパッケージ名のプレフィックスを設定します。

  説明

  環境変数は、JobManager と TaskManager の両方で利用できるように、containerized.master.env. と containerized.taskmanager.env. の両方のプレフィックスを付けて構成する必要があります。

Python

仮想環境の使用を推奨します：

python3 -m venv flink-agents-env
source flink-agents-env/bin/activate
pip install flink-agents       

詳細については、「Flink Agents Installation Guide」をご参照ください。

Java

pom.xml ファイルに次の依存関係を追加します：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-api</artifactId>
    <version>${flink-agents.version}</version>
    <scope>provided</scope>
</dependency>

ローカル IDE でデバッグする場合は、次の依存関係を追加します：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-agents-ide-support</artifactId>
    <version>${flink-agents.version}</version>
    <scope>provided</scope>
</dependency>

Python インタプリタのバージョン

VVR エンジンイメージのデフォルトは Python 3.9 ですが、Flink Agents には Python 3.10 または 3.11 が必要です。Python ジョブでは次のように構成する必要があります：

python.executable: python3.10
python.client.executable: python3.10
containerized.master.env.FLINK_HOME: /flink
containerized.taskmanager.env.FLINK_HOME: /flink

カスタム環境変数

ジョブコードが環境変数 (エンドポイント URL やモデル選択など) から設定を読み取る場合は、それぞれのプレフィックスを使用して JobManager と TaskManager プロセスの両方に変数を設定する必要があります：

containerized.master.env.<ENV_VAR_NAME>: <value>
containerized.taskmanager.env.<ENV_VAR_NAME>: <value>        

モデルを切り替える例：

containerized.master.env.OPENAI_MODEL: qwen3.6-flash
containerized.taskmanager.env.OPENAI_MODEL: qwen3.6-flash