Scala シェルを使用する - Amazon EMR

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Scala シェルを使用する

EMR クラスターの Flink Scala シェルは、YARN の新規セッションを開始する目的でのみ設定できます。次の手順に従って Scala シェルを使用できます。

プライマリノードで Flink Scala シェルを使用する

  1. 「SSH を使用してプライマリノードに接続する」の説明どおり、プライマリノードに SSH でログインします。

  2. 次のように入力してシェルを開始します。

    Amazon EMR バージョン 5.5.0 以降では、次のコマンドを使用して、1 つの 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」を参照してください。