control event pileline does not take effect

[laityc]

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]

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?

[laityc]

@haoch

[haoch]

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