是的,一个Executor中只能运行属于同一个Spout/Bolt的Task。这是因为Spout/Bolt在并行执行时需要保证线程安全,因此需要将同一个Spout/Bolt的Task分配给同一个物理线程来执行,避免并发冲突。如果将不同Spout/Bolt的Task分配给同一个物理线程来执行,可能会导致并发冲突和数据不一致的问题。

Executor为 Worker 进程中的具体的物理线程同一个 SpoutBolt的Task可能会共享一个物理线程一个Executor 中只能运行隶属于同一个SpoutBoltC的Task吗

原文地址: http://www.cveoy.top/t/topic/hpp8 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录