本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
使用 Scala Shell
适用于 EMR 集群的 Flink Scala Shell 仅配置为启动新的 YARN 会话。您可以通过以下过程使用 Scala Shell。
在主节点上使用 Flink Scala Shell
-
使用 SSH 登录主节点,如 Connect to the primary node with SSH 中所述。
-
键入以下命令启动 Shell:
在 Amazon EMR 5.5.0 及更高版本中,您可以借助一个 TaskManager 来使用以下命令启动 Scala Shell Yarn 集群。
% flink-scala-shell yarn
1
在 Amazon EMR 的更早版本中,使用:
% /usr/lib/flink/bin/start-scala-shell.sh yarn
1
这将启动 Flink Scala Shell,以便您能以交互方式使用 Flink。与使用其它接口和选项一样,您可以基于要从 Shell 运行的任务数来缩放示例中使用的
-n
选项值。有关更多信息,请参阅官方 Apache Flink 文档中的 Scala REPL
。