Utilisation du shell Scala - Amazon EMR

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Utilisation du shell Scala

Le shell Scala Flink pour les clusters EMR n'est configuré que pour démarrer de nouvelles sessions de YARN. Vous pouvez utiliser le shell Scala en suivant la procédure ci-dessous.

Utilisation du shell Flink Scala sur le nœud primaire

  1. Connectez-vous au nœud primaire avec SSH comme décrit dans Connexion au nœud primaire avec SSH.

  2. Tapez ce qui suit pour démarrer un shell :

    Dans Amazon EMR version 5.5.0 et versions ultérieures, vous pouvez utiliser la commande suivante pour démarrer un cluster Yarn pour le Scala Shell avec un seul TaskManager.

    % flink-scala-shell yarn 1

    Dans les versions antérieures d'Amazon EMR, utilisez :

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

    Cela démarre le shell Scala Flink pour que vous puissiez utiliser Flink de façon interactive. Tout comme avec les autres interfaces et options, vous pouvez faire évoluer la valeur de l'option -n utilisée dans l'exemple basé sur le nombre de tâches à exécuter à partir du shell.

    Pour plus d'informations, consultez Scala REPL dans la documentation officielle d'Apache Flink.