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)

シャッフル グループを持つボルトをその前のボルトに接続すると、IndexOutOfBoundsException が発生します。

先代のボルトはこれを投げます。後続のボルトには 8 つのインスタンスがあるため、8 と表示されます。

何か案は？

4

2 に答える 2

0

ボルトがスパウト自体から入力を受けているかどうかを確認してください。スパウト自体から空の値を発行しようとしたときに発生する可能性があります。

于 2013-10-28T12:49:20.570 に答える
0

それは嵐のバグであることが判明しました。今のところ、エミットをロックする必要があります。

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

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

于 2013-10-29T10:36:57.343 に答える