search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

Control Event is broadcasted twice Bug #60

Closed pranjal0811 closed 4 years ago

pranjal0811 commented 4 years ago

Control stream is broadcasted twice to the downstream operator.

As control stream broadcasted first, then union with event stream, then the union stream goes to Add Route Operator. Where all the mapping is done with the event and control stream.

Then the dynamic partitioning takes place, If the upstream is NamedControlStream then it got broadcasted again to Siddhi-cep-operator. Which degrades the performance and increases the siddhi manager threads on each parallel instance.

I am raising PR for solving this issue.

pranjal0811 commented 4 years ago

As I see its already fixed in latest commits.