ฉันใช้ storm เพื่อประมวลผลปัญหาออนไลน์ แต่ฉันไม่เข้าใจว่าทำไม storm จึงเล่นซ้ำ tuple จาก spout การลองใหม่กับสิ่งที่ขัดข้องอาจมีประสิทธิภาพมากกว่าการเล่นซ้ำจากรูทใช่ไหม ใครสามารถช่วยฉันได้บ้าง? ขอบคุณ

หลังจากใช้โทโพโลยี apache storm ที่เรียบง่ายใน java ฉันพบ NPE ซึ่งทำให้เกิดความสับสน นี่เป็นวิธีการหลักของฉัน: TologyBuilder builder = new TopologyBuilder(); builder.setSpout("spout", new CustomSpout(true), 4); final CustomBolt bolt = new...

ฉันมีปัญหาเล็กน้อยในการบันทึกไฟล์โดยใช้ log4j ใน storm ก่อนที่จะส่งโทโพโลยีของฉัน เช่น ในวิธีการหลักของฉัน ฉันเขียนคำสั่งบันทึกและกำหนดค่าตัวบันทึกโดยใช้: PropertyConfigurator.configure(myLog4jProperties) ตอนนี้เมื่อฉันรันโทโพโลยีโดยใช้...

ทุกคน ฉันต้องการทำงาน—— พวยหนึ่งปล่อยตัวเลขไปที่ blotA และ BlotA ปล่อยเลขคี่ไปที่ Blot_odd BlotA ปล่อยเลขคู่ไปที่ Blot_even ฉันเลือกวิธีใช้ emit(streamId,tuple) แต่ฉันไม่รู้ว่าจะกำหนด streamId ของฉันที่ไหน ใน Blot_odd / Blot_even...