Gunakan shell Scala - Amazon EMR

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Gunakan shell Scala

Shell Flink Scala untuk cluster EMR hanya dikonfigurasi untuk memulai sesi YARN baru. Anda dapat menggunakan shell Scala dengan mengikuti prosedur di bawah ini.

Gunakan shell Flink Scala pada node utama

  1. Masuk ke node primer dengan SSH seperti yang dijelaskan dalam Connect to the primary node dengan SSH.

  2. Ketik berikut ini untuk memulai shell:

    Di Amazon EMR versi 5.5.0 dan yang lebih baru, Anda dapat menggunakan perintah berikut untuk memulai cluster Yarn untuk Scala Shell dengan satu. TaskManager

    % flink-scala-shell yarn 1

    Dalam versi sebelumnya dari Amazon EMR, gunakan:

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

    Ini memulai shell Flink Scala agar Anda dapat secara interaktif menggunakan Flink. Sama seperti dengan antarmuka lain dan pilihan, Anda dapat menskalakan -n nilai opsi yang digunakan dalam contoh berdasarkan jumlah tugas yang ingin Anda jalankan dari shell.

    Untuk informasi lebih lanjut, lihat REPL Scala dalam dokumentasi Apache Flink resmi.