IndexOutOfBoundsException в случайном порядке группировке

Question

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, когда мы подключаем болт с случайным порядком группировкой его предшественником болтом.

Болт предшественника бросает это. Он говорит 8, потому что у преемника-болта 8 экземпляров.

Любые идеи?

Answer 1

Это оказалось ошибкой в ​​шторме. На данный момент вам нужно заблокировать излучение.

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

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

Answer 2

Можете ли вы проверить, принимает ли ваш болт вход от самого желоба. Возможно, произойдет, когда вы попытаетесь испустить пустое значение из самого желоба.