GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3307
[FLINK-5420] Make CEP operators rescalable
Transforms the CEP operators into ProcessFunctions that use only managed
keyed state. Rescalability now comes out-of-the-box. In addition, for the keyed
operator, the list of seen keys is replaced by timers set by the incoming
elements that will fire at the next watermark.
More information about how rescalability is achieved can be found here:
https://issues.apache.org/jira/browse/FLINK-5420
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink cep-ref
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3307.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3307
----
commit 230ee80355f7219d56d1010d8850dbe39866c7e8
Author: kl0u <[email protected]>
Date: 2017-01-27T14:30:32Z
[FLINK-5420] Make CEP operators rescalable
Transforms the CEP operators into ProcessFunctions
that use only managed keyed state. Rescalability
now comes out-of-the-box. In addition, for the
keyed operator, the list of seen keys is replaced
by timers set by the incoming elements that will
fire at the next watermark.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
