Skip to content

Compatibility with storm 0.9.0.1 #6

@Alien2150

Description

@Alien2150

Hi,

i think the current stormcpp is not compatible with storm 0.9.0.1 as sending the task ids is optional (See the handleEmit method, especial the "need_task_ids" part in https://github.com/apache/incubator-storm/blob/master/storm-core/src/jvm/backtype/storm/task/ShellBolt.java ). The C++ Code is always expecting it to send the task-ids. The best solution i can think of here is to add an extra parameter to the emit method so that reading of task-ids is optional. I can provide a pull request if that is prefered.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions