我的 Storm 拓扑中的一个螺栓引用了一个实用类中的一个静态变量，并且这个静态变量对于在一个工作进程上处理的每个元组都保持相同吗？
moiiocjp1#
任务并不是为每个元组创建的。一旦任务在执行器线程上启动，元组将流向此任务。因此，静态变量将在元组之间共享。任务线程将一直保持在那里，直到线程出现问题，并为任务分配了新线程。因此，在我的场景中，静态变量是不能使用的。因此，将逻辑更改为没有静态变量。
1条答案
按热度按时间moiiocjp1#
任务并不是为每个元组创建的。一旦任务在执行器线程上启动，元组将流向此任务。因此，静态变量将在元组之间共享。
任务线程将一直保持在那里，直到线程出现问题，并为任务分配了新线程。因此，在我的场景中，静态变量是不能使用的。因此，将逻辑更改为没有静态变量。