我试图使用apachestorm并行化我的拓扑结构，但是它给了我 java.util.ConcurrentModificationException 如果我将worker的数量增加到>1，则worker节点出错。它可以在本地集群中与1个worker一起工作。我想要一种方法来并行化我的拓扑，并测量不同的参数，如吞吐量，延迟，发射率等，只使用一个工人节点。
java.util.ConcurrentModificationException
fumotvh31#
根据您发布的堆栈跟踪，kryo似乎正在尝试序列化arraylist并遇到concurrentmodificationexception。我会寻找任何你发出一个arraylist的地方，并确保在你把它传递给我之后你不会修改它 OutputCollector.emit .当您只有一个工作进程时，您没有看到此问题的原因可能是，storm仅在需要将发出的对象发送到其他工作进程时序列化这些对象。
OutputCollector.emit
1条答案
按热度按时间fumotvh31#
根据您发布的堆栈跟踪，kryo似乎正在尝试序列化arraylist并遇到concurrentmodificationexception。我会寻找任何你发出一个arraylist的地方，并确保在你把它传递给我之后你不会修改它
OutputCollector.emit.当您只有一个工作进程时，您没有看到此问题的原因可能是，storm仅在需要将发出的对象发送到其他工作进程时序列化这些对象。