0 
    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)

当我们将一个带有 shuffle 分组的 bolt 连接到它的前一个 bolt 时，我们会得到 IndexOutOfBoundsException。

前身螺栓抛出这个。它说 8 因为后继螺栓有 8 个实例。

有任何想法吗？

4

2 回答 2

0

您能否检查一下您的螺栓是否从喷口本身接收输入。当您尝试从 spout 本身发出空值时，可能会发生这种情况。

于 2013-10-28T12:49:20.570 回答
0

原来是暴风雨中的一个错误。您现在需要锁定发射。

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

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

于 2013-10-29T10:36:57.343 回答