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: [email protected] With regards, Apache Git Services
