使用 Flink 创建集群

您可以使用 AWS Management Console AWS CLI、或 AWS SDK 启动集群。

使用控制台启动安装了 Flink 的集群

1. 打开亚马逊 EMR 控制台，网址为 https://console.aws.amazon.com/emr。

2. 依次选择 Create cluster (创建集群)、Go to advanced options (转到高级选项)。

3. 对于 Software Configuration (软件配置)，选择 EMR Release emr-5.1.0 (EMR 版本 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，请将它们删除或替换为脱字号 (^)。