Looks like its a bug

[1]https://issues.apache.org/jira/browse/STORM-66

There is a patch available.

Thanks,

Harsha



On Mon, May 26, 2014, at 03:41 PM, Dilpreet Singh wrote:

Hi,

I've initialized the bolt like this:

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

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

The context object looks like this:

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

But does not contain the taskid parameter.

Please help.

Regards,

Dilpreet

References

1. https://issues.apache.org/jira/browse/STORM-66
2. https://github.com/nathanmarz/storm/wiki/Multilang-protocol

Reply via email to