0
私はFlinkの初心者です。 bin/yarn-session.sh
を実行したときにResourceManagerのアドレスを指定する方法が混乱していますか?bin/yarn-session.shにResourceManagerのアドレスを指定する方法は?
私はFlinkの初心者です。 bin/yarn-session.sh
を実行したときにResourceManagerのアドレスを指定する方法が混乱していますか?bin/yarn-session.shにResourceManagerのアドレスを指定する方法は?
bin/yarn-session.sh
でFlink Yarnセッションを開始すると、.yarn-properties-USER
というファイルがtmpディレクトリに作成されます。このファイルには、Flinkクラスタの接続情報が含まれます。 bin/flink run <JOB_JAR>
でジョブを送信しようとすると、クライアントはこのファイルからの接続情報を使用します。