如何在 apache Flink 中动态/在运行时添加/更改新模式/查询？

Question

我正在尝试使用 Apache Flink 构建一个 CEP 系统来关联事件。要求之一是能够在运行时为异常检测添加新模式，而不会丢失系统可用性。关于我该怎么做的任何想法？

例如，如果我有一系列安全事件（例如访问、身份验证）和用于检测异常的模式（例如，在 1 分钟内登录同一台机器超过 10 次），我希望能够更改模式参数，例如，而不是 10 次登录，也许我想要 8 次，同时我希望能够创建其他模式（维护相同的流）来检测新类型的异常，而不会丢失事件/系统可用性。

问候。

Answer 1

Adding patterns dynamically in Apache Flink without restarting job 已经回答了这个问题

基本上，由于Flink CEP 现在已编码，因此您不能这样做。预计未来版本中会提供此功能，但我们会一直等待。