使用 Scala Shell

在主节点上使用 Flink Scala Shell

1. 使用 SSH 登录主节点，如 Connect to the primary node with SSH 中所述。

2. 键入以下命令启动 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。