Amazon EMR
Amazon EMR 版本指南
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

使用 Scala 外壳

目前,适用于 EMR 集群的 Flink Scala 外壳仅配置为启动新的 YARN 会话。您可以通过以下过程使用 Scala 外壳。

在主节点上使用 Flink Scala 外壳

  1. 使用 SSH 连接到主节点中所述,使用 SSH 登录到主节点。

  2. 键入以下命令启动外壳:

    在 Amazon EMR 版本 5.5.0 及更高版本中,您可以:

    % flink-scala-shell yarn -n 1

    在 Amazon EMR 早期版本中,使用:

    % /usr/lib/flink/bin/start-scala-shell.sh yarn -n 1

    这将启动 Flink Scala 外壳,以便您能以交互方式使用 Flink。与使用其他接口和选项一样,您可以基于要从外壳运行的任务数来缩放示例中使用的 -n 选项值。