拋出IndexOutOfBoundsException在洗牌分組

Caused by: java.lang.IndexOutOfBoundsException: Index: 8, Size: 8 
     at java.util.ArrayList.get(ArrayList.java:382) 
     at backtype.storm.util$acquire_random_range_id.invoke(util.clj:590) 
at backtype.storm.daemon.executor$mk_shuffle_grouper$fn__3568.invoke(executor.clj:28) 
... 
     at backtype.storm.task.OutputCollector.emit(OutputCollector.java:186)

我們得到IndexOutOfBoundsException異常，當我們有洗牌分組螺栓連接到它的前身螺栓。拋出IndexOutOfBoundsException在洗牌分組

先前的螺栓拋出這個。它說8，因爲後繼螺栓有8個實例。

任何想法？

來源

2013-10-28 Fakrudeen

哪個版本的風暴？ – Chiron

storm-0.9.0版本 – Fakrudeen

看起來您在分組時的元組數量不匹配。重新檢查你的配置。 – Chiron

原來是風暴中的一個bug。現在需要鎖定發射。

synchronized(outputCollector) { 
    outputCollector.emit(); 
}

https://github.com/nathanmarz/storm/issues/724

來源

2013-10-29 10:36:57 Fakrudeen

您能檢查一下您的螺栓是否接收到噴口本身的輸入。當你試圖從噴口本身發出一個空值時可能發生。

來源

2013-10-28 12:49:20 user2720864

是的 - 我正在接收來自噴口的輸入信息。 – Fakrudeen

我只能通過從噴口發出一個空值來重現相同的異常。正如你所說，這個錯誤是隨機的，你可以確認你的水口在接收到這個異常之前已經發出了什麼值 – user2720864

拋出IndexOutOfBoundsException在洗牌分組

回答

相關問題