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
-
Connectez-vous au nœud primaire avec SSH comme décrit dans Connexion au nœud primaire avec SSH.
-
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. TaskManager
% flink-scala-shell yarn1Dans les versions antérieures d'Amazon EMR, utilisez :
% /usr/lib/flink/bin/start-scala-shell.sh yarn1Cela 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
-nutilisé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.
