You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Frank <fr...@qq.com.INVALID> on 2022/09/21 02:03:40 UTC

如何停止一个CEP Pattern?

一般而言,我这么开始一个Pattern:


Pattern<Event, ?&gt; patternA = getPattern();
PatternStream<Event&gt; patternStreamA = CEP.pattern(keyedStream, patternA).inProcessingTime();
DataStream<String&gt; resultStream = patternStreamA.process(getProcessFunc());
resultStream.print();


这样,patternStreamA就开始运行了。


那么,有一天我由于patternA CEP规则变了,想要停掉patternStreamA(然后重新创建一个patternB)
请问我如何才能停掉patternStreamA(不再耗资源)?


--Frank