当前位置: 首页 > 知识库问答 >
问题:

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

松德曜
2023-03-14

我正试图用Apache Flink构建一个CEP系统来关联事件。其中一个要求是能够在运行时为异常检测添加新模式,而不会丢失系统可用性。你知道我该怎么做吗?

例如,如果我有一个安全事件流(例如访问、身份验证)和一个用于检测异常的模式(例如,

问候。

共有1个答案

钮边浩
2023-03-14

在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起,不建议使用 要改回它,你可以使用以下命令:

  • 我不熟悉JTable。 我想在button press事件中在运行时更新jtable数据。 这是我的密码。 但按下“更新”按钮后不会更新。 有人能解决我的问题吗? 提前谢谢。。