Uso del intérprete de comandos de Scala

El intérprete de comandos de Scala de Flink para clústeres de EMR solo está configurado para iniciar nuevas sesiones de YARN. Puede utilizar el shell Scala con el procedimiento siguiente.

Uso del intérprete de comandos de Scala de Flink en el nodo principal

1. Inicie sesión en el nodo principal con SSH, tal y como se describe en Conectarse al nodo principal utilizando SSH.

2. Escriba lo siguiente para iniciar un shell:

   En la versión 5.5.0 y posteriores de Amazon EMR, puede usar el siguiente comando para iniciar un clúster de Yarn para el intérprete de comandos de Scala con un TaskManager.

   % flink-scala-shell yarn 1

   En las versiones anteriores de Amazon EMR, utilice:

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

   Esto inicia el shell Scala de Flink para que pueda utilizar de forma interactiva Flink. De la misma forma que con otras interfaces y opciones, puede escalar el valor de opción -n utilizado en el ejemplo en función del número de tareas que desea ejecutar desde el shell.

   Para obtener más información, consulte Scala REPL en la documentación de Apache Flink.