[GitHub] [incubator-heron] simingweng opened a new issue #3234: ECO is not handling bolt of type IStatefulWindowedBolt

[GitBox <gi...@apache.org>]

simingweng opened a new issue #3234: ECO is not handling bolt of type IStatefulWindowedBolt
URL: https://github.com/apache/incubator-heron/issues/3234
 
 
   Neither `heron` nor `storm` flavor of ECO `StreamBuilder` is handling a bolt object of type `IStatefulWindowedBolt`. It only handles the bolt if it is a `IWindowedBolt` at https://github.com/apache/incubator-heron/blob/bc4719746bf613bc5eaf4c3781a435ceb6349198/eco/src/java/org/apache/heron/eco/builder/heron/StreamBuilder.java#L71
   
   When the bolt is of type `IStatefulWindowedBolt ` which extends `IWindowedBolt `, the stream builder will only treat it as `IWindowedBolt`, resulting in invoking https://github.com/apache/incubator-heron/blob/bc4719746bf613bc5eaf4c3781a435ceb6349198/heron/api/src/java/org/apache/heron/api/topology/TopologyBuilder.java#L191, wrapping the bolt in a `WindowedBoltExecutor `, therefore, the `statefulness` of the bolt is lost, it's treated as a plain windowed bolt.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services