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

fix handler npe #67

Open rovboyko opened 4 years ago

rovboyko commented 4 years ago

PR corrects the situation when data stream events are assigned to partitions by AddRouteOperator, but control events aren't. This happens because control events can't be distributed on broadcast rule through the DynamicPartitioner. PR also fixes NPE in testDynamicalStreamSimplePatternMatch().

64