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

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

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

1. Amazon EMR コンソール (https://console.aws.amazon.com/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-5.36.1 \
  --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 の場合、削除するか、キャレット (^) に置き換えてください。