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