使用 Scala 外壳 - Amazon EMR
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 Amazon Web Services 服务入门

使用 Scala 外壳

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

在主节点上使用 Flink Scala 外壳

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

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

    在 Amazon EMR 5.5.0 及更高版本中,您可以借助一个 TaskManager 来使用以下命令启动 Scala 外壳 Yarn 集群。

    % flink-scala-shell yarn 1

    在 Amazon EMR 的更早版本中,使用:

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

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

    有关更多信息,请参阅官方 Apache Flink 文档中的 Scala REPL