Flink を使用してクラスターを作成する

クラスターは、 AWS Management Console、 AWS CLI、または AWS SDK を使用して起動できます。

Flink がインストールされたクラスターをコンソールから起動するには

1. https://console.aws.amazon.com/emr で Amazon EMR コンソールを開きます。

2. [Create cluster (クラスターの作成)]、[Go to advanced options (詳細オプションに移動する)] の順に選択します。

3. [Software Configuration (ソフトウェア設定)] で、EMR Release emr-5.1.0 以降を選択します。

4. インストールする他のアプリケーションとともに、アプリケーションに [Flink] を選択します。

5. 必要に応じて他のオプションを選択し、[Create cluster (クラスターの作成)] を選択します。

から Flink を使用してクラスターを起動するには AWS CLI

• 次のコマンドを使用してクラスターを作成します。

  aws emr create-cluster --release-label emr-7.1.0 \
  --applications Name=Flink \
  --configurations file://./configurations.json \
  --region us-east-1 \
  --log-uri s3://myLogUri \
  --instance-type m5.xlarge \
  --instance-count 2 \
  --service-role EMR_DefaultRole_V2 \ 
  --ec2-attributes KeyName=MyKeyName,InstanceProfile=EMR_EC2_DefaultRole \
  --steps Type=CUSTOM_JAR,Jar=command-runner.jar,Name=Flink_Long_Running_Session,\
  Args=flink-yarn-session,-d

  注記

  読みやすくするために、Linux 行連続文字 (\) が含まれています。Linux コマンドでは、これらは削除することも、使用することもできます。Windows の場合、削除するか、キャレット (^) に置き換えてください。