Kode ini berfungsi dengan baik: .keyBy(value -> value.getSessionUid()) tapi ini .keyBy(LogItem::getSessionUid) pengecualian lemparan: Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1 at...

Saya mencoba mengonfigurasi Flink 1.2.0 untuk pengaturan HA dan di sana saya harus menyetel parameter yang disebut state backend. Saya telah menetapkan parameter ini ke rocksdb sebelumnya tetapi kemudian membaca dokumentasi yang mengatakan hanya...

Saya menggunakan konektor pencarian elastis flink untuk mengirim data ke indeks pencarian elastis. Tapi saya tidak dapat menjalankan pekerjaan dan mendapatkan pengecualian ini. Bagaimana cara mengatasi masalah ini?. Apakah ada pengaturan atau...

Lihat panduan pemrograman python online: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html Saya tidak melihat materi apa pun yang terkait dengan pemrograman streaming seperti konektor kafka dan sebagainya . Juga...

Saya ingin menyesuaikan nama tugas di dasbor Apache flink. Misalnya, ketika kita memiliki peta tugas di dashboard namanya MAP, bagaimana cara mengubahnya untuk menambahkan nama tertentu? Terima kasih banyak.

Apakah mungkin untuk menjalankan pengelola tugas Flink pada simpul Tugas AWS EMR? Jika ya, apa bedanya dengan menjalankan Task Manager pada node inti?

Saya menggunakan WordCountProg dari tutorial di https://www.tutorialspoint.com/apache_flink/apache_flink_creating_application.htm . Kodenya adalah sebagai berikut: WordCountProg.java package main.java.spendreport; import...