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

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

使用 Scala 外壳

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

在主节点上使用 Flink Scala 外壳

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

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

    在 Amazon EMR 5.5.0 版及更高版本中,您可以使用以下命令启动 Scala 命令行管理程序的 Yarn 集群,并使用一个任务管理器。

    % flink-scala-shell yarn 1

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

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

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

    有关更多信息,请参阅 。Scala Repl在官方的阿帕奇弗林克文档中。