Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.5.0
-
None
Description
In class org.apache.s4.core.Stream:
public Stream<T> setPE(ProcessingElement pe)
{ app.addStream(this); return this; }This method implementation is wrong, should add argument pe into targetPEs list, not addStream()