Menggunakan shell Scala - Amazon EMR

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

Menggunakan shell Scala

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

Menggunakan shell Flink Scala pada simpul utama
  1. Masuk ke simpul utama menggunakan SSH seperti yang dijelaskan di Connect ke simpul utama menggunakan 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 klaster 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.