Apache Storm 从 python bolt 调用函数

Question

我有一个简单的风暴螺栓，它只需要从另一个 python 模块调用一个函数。一切正常，直到我调用一个在函数内部有打印语句的方法。

所以我的螺栓：

import storm
from pipeline import module as m

class ExampleBolt(storm.BasicBolt): 

    def initialize(self, conf, context):
        self._conf = conf;
        self._context = context;
        storm.logInfo("ExampleBolt instance starting ...")

    def process(self, tuple):
        id, text = tuple.values
        result = m.dummy_funct(text)        
        storm.emit([result])         


ExampleBolt().run()

方法：

def dummy_funct(text):
    print "log info"
    return text

bolt 调用该方法一次，然后在输出时挂起。使用 Apache Storm 0.9.3

Answer 1

检查是否从第二次开始只执行进程块。
不是整个程序都在执行。