Hi,

I've initialized the bolt like this:

def initialize(self, stormconf, context):
        self.stormconf = stormconf
        self.context = context

However, contrary to what
https://github.com/nathanmarz/storm/wiki/Multilang-protocol says, 'context'
does not contain the task id of the bolt.

The context object looks like this:

{"task->component":{"13":"spout","11":"idfvectorizer","12":"idfvectorizer","3":"idfvectorizer","2":"clusterer","10":"idfvectorizer","1":"__acker","7":"idfvectorizer","6":"idfvectorizer","5":"idfvectorizer","4":"idfvectorizer","9":"idfvectorizer","8":"idfvectorizer"}}

But does not contain the taskid parameter.

Please help.

Regards,

Dilpreet

Reply via email to