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 pileline does not take effect #41

Open laityc opened 5 years ago

laityc commented 5 years ago

I found a strange problem，When the control event data source is in a continuous running state, such as kafka, or simple datasource with an infinite loop ， the execution plan added by the control event does not take effect and the rules cannot be dynamically added or deleted. When the control event source is in the finished state, the rule can take effect. I don't know if it is my operation problem.

laityc commented 5 years ago

When I lengthen the sleep time of the thread in the overried run method of extended datasource class, the rule does not take effect during this time.When the sleep time is over, the control event source enters the finished state, and the rule takes effect.

is it? image

laityc commented 5 years ago

@haoch

haoch commented 4 years ago

@laityc ack, looking into the problem. Thanks for reporting.