รหัสนี้ใช้งานได้ดี: .keyBy(value -> value.getSessionUid()) แต่นี่ .keyBy(LogItem::getSessionUid) โยนข้อยกเว้น: Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1 at...

ฉันกำลังพยายามกำหนดค่า Flink 1.2.0 สำหรับการตั้งค่า HA และฉันต้องตั้งค่าพารามิเตอร์ที่เรียกว่าแบ็กเอนด์สถานะ ฉันได้ตั้งค่าพารามิเตอร์นี้เป็น rocksdb ก่อนหน้านี้ แต่จากนั้นอ่านเอกสารที่ระบุว่าสำหรับระบบไฟล์ HA เท่านั้นที่พร้อมใช้งาน...

ฉันกำลังใช้ตัวเชื่อมต่อการค้นหาแบบยืดหยุ่น flink เพื่อส่งข้อมูลไปยังดัชนีการค้นหาแบบยืดหยุ่น แต่ฉันไม่สามารถรันงานและรับข้อยกเว้นนี้ได้ วิธีแก้ปัญหานี้?.มีการตั้งค่าหรือการกำหนดค่าใด ๆ ที่ฉันขาดหายไปหรือไม่? ใครช่วยแนะนำฉันได้บ้าง?...

อ้างอิงถึงคู่มือการเขียนโปรแกรม python ออนไลน์: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/python.html ฉันไม่เห็นเนื้อหาใด ๆ ที่เกี่ยวข้องกับการเขียนโปรแกรมสตรีมมิ่งเช่นตัวเชื่อมต่อ kafka และอื่น ๆ ....

ฉันต้องการปรับแต่งชื่อของงานในแดชบอร์ด apache flink เช่น เมื่อเรามี Task Map ในแดชบอร์ดชื่อ MAP จะเปลี่ยนให้เป็นชื่อเฉพาะได้อย่างไร ขอบคุณมาก.

เป็นไปได้ไหมที่จะรันตัวจัดการงาน Flink บนโหนดงานของ AWS EMR ถ้าใช่ มันแตกต่างจากการรันตัวจัดการงานบนโหนดหลักอย่างไร

ฉันใช้ WordCountProg จากบทช่วยสอนบน https://www.tutorialspoint.com/apache_flink/apache_flink_creating_application.htm . รหัสมีดังนี้: WordCountProg.java package main.java.spendreport; import...