Utilizzo della shell Scala

Attualmente, la shell Scala di Flink per i cluster EMR è configurata solo per avviare nuove sessioni YARN. È possibile utilizzare la shell Scala seguendo la procedura riportata di seguito.

Utilizzo della shell Scala di Flink sul nodo primario

1. Accedi al nodo primario con SSH come descritto in Connessione al nodo primario con SSH.

2. Per avviare una shell, digitare quanto segue:

   In Amazon EMR versione 5.5.0 e successive, è possibile utilizzare il seguente comando per avviare un cluster Yarn per la shell Scala con un TaskManager.

   % flink-scala-shell yarn 1

   Nelle versioni precedenti di Amazon EMR, utilizza:

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

   In questo modo si avvia la shell di Flink Scala in modo da poter utilizzare Flink interattivamente. Come per altre interfacce e opzioni, è possibile dimensionare il valore dell'opzione -n utilizzato nell'esempio in base al numero di attività che si desidera eseguire dalla shell.

   Per ulteriori informazioni, consulta Scala REPL nella documentazione ufficiale di Apache Flink.