如何在apache Flink中动态/在运行时添加/更改新模式/查询？
我正试图用Apache Flink构建一个CEP系统来关联事件。其中一个要求是能够在运行时为异常检测添加新模式，而不会丢失系统可用性。你知道我该怎么做吗？
例如，如果我有一个安全事件流（例如访问、身份验证）和一个用于检测异常的模式（例如，
问候。
共有1个答案
在Apache Flink中动态添加模式而不重新启动作业时，已经解决了这一问题
基本上，由于Flink CEP现在正在编码，您无法执行此功能。预计此功能将用于未来的版本，但我们仍在等待它。
-
我找了很长时间，所以在标记为重复之前，请务必阅读。 我有一个函数（），它是用一个参数调用的。我想将该id作为前缀添加到每个日志消息中。每次调用函数时，它都会更改。因此，我想更新记录器模式，将此id添加为前缀。 我读过： 如何配置 如何重新配置 SO和log4j论坛上的许多帖子都在讨论如何在运行时更改配置。它们要么过时，要么根本不起作用。 以下代码基于 log4j2 文档。它打印： 如果我注释掉行然
-
我有一个用TypeScript编写的非常简单的应用程序： src/索引。输电系统 然后我的TypeScript配置： tsconfig.json 我可以使用npx tsc构建代码，然后使用节点运行它/构建/索引。js，访问时http://localhost:3000在浏览器中，我看到一条消息“你好，世界”--到目前为止一切都很好 现在使用我可以观察文件，看看它们是否发生变化，并在发生这种情况时重新
-
我是playframework应用程序开发人员。我使用jpa中的createNativeQuery方法通过select查询从表中提取值。我需要使用更新查询。我要做的是什么，以及该方法的返回类型是什么。请任何人帮助我。提前谢谢。如果我这样使用，它会显示错误。。 Query query=JPA.em()。createNativeQuery(" update truck set flag = ' YES
-
首先，我要说的是，我已经搜索并发现了许多与此类似的问题，但我发现的所有问题都使用jquery、bootstrap、react等。。。，而我只是想要一个简单的HTML/CSS/JS解决方案。 更改反应模式数据动态启动模式，在动态按钮上动态添加按钮模式弹出窗口 我拿了W3School的代码，做了一些调整来测试我的理论，结果让我相信动态创建的按钮不能改变html中现有的元素。https://www.w3
-
问题内容： 我有一个Android应用程序，当用户点击时，我想应用定义的样式。 我以为找到一个，但它不存在。我试过了 但它不起作用。 问题答案： 我通过创建一个新的XML文件来做到这一点，如下所示： 我的文件中也有一个条目，如下所示： 然后，在我的代码中，我创建了一个来捕获该上的tap事件： 编辑： 自API 23起，不建议使用 要改回它，你可以使用以下命令：
-
问题内容： 我正在忙于配置一个TensorFlow Serving客户端，该客户端要求TensorFlow Serving服务器针对给定模型在给定输入图像上生成预测。 如果尚未提供所请求的模型，则将其从远程URL下载到服务器模型所在的文件夹中。（客户端执行此操作）。此时，我需要更新和触发服务器以重新加载它。 该功能似乎存在（基于https://github.com/tensorflow/servi