使用 Scala Shell - Amazon EMR

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

使用 Scala Shell

EMR 叢集的 Flink Scala Shell 僅設定為啟動新的 YARN 工作階段。您可按照以下步驟來使用 Scala Shell。

在主節點上使用 Flink Scala Shell

  1. 使用 SSH 登入主節點，如使用 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。