在Flink运算符之间共享状态
这个问题在这里已经被问到了，但是两年过去了，我想知道是否有什么改变。
我有一个用例，我希望在两个Flink操作符之间共享状态：
>
流B有一个与之相关联的运算符(FlatMap，但可以是任何实际的），它充当状态加载器，并将浓缩数据作为列表状态加载到RocksDB中。
-
null
共有1个答案
- 实际上很难“简单地加载整个状态”，因为您无法控制加载的顺序。通常情况下，您希望在处理任何主流之前完全加载浓缩数据（参见FLIP-23)。
- 抛开这个不谈，我不认为它是“状态加载”。基本上，您将充实数据缓存到需要的地方（在充实函数中）。
- 最后，不，我不知道在Flink中有一种简单的内置方式在操作符之间共享状态。显然，您可以使用一些外部键值存储来启用此功能，但(a)这是额外的基础结构，(b)它不会像性能一样。
-
我想知道在Flink中是否可以在运营商之间共享状态。 比方说，我在一个操作符上按键进行分区，我需要一个分区的状态（无论出于什么原因）（图1.a），或者我需要下游操作符中操作符的状态（图1.b）。 我知道可以将记录广播到所有分区。因此，如果在记录中包含操作符的内部状态，则可以与下游操作符共享内部状态 然而，这可能是一个昂贵的操作，而不是简单地让op1专门请求op2状态。 可查询状态的最新发展是朝着这
-
使用时有点卡住了。如果我把它放在before窗口上，它似乎可以正常工作，但如果放在窗口的“apply”函数之后，它就会失败。 我正在测试两个流，主功能在不断摄取数据和控制流模型在更改模型的要求。 我能够在中正确设置并查看b0/b1，但是始终可以看到b0和b1在初始化时设置为0。 我是不是漏了什么明显的东西？
-
我有一个测试类的testng套件，我正在通过一个testng.xml文件运行它。这个很管用。所有测试都是串行运行的，因此没有并行执行障碍。 当然，通过类成员变量在单个类中的测试方法之间共享状态是很容易的，但是我不知道如何在测试类之间共享状态。
-
我正在实现一个流式应用程序，其中一个有状态运算符正试图捕获“所有者有项目”的关系。每个所有者键入的状态由有关所有者和每个项目的详细信息组成。项目的所有权可以更改，我希望能够将每个项目与其正确的所有者相关联。由于不同所有者的操作员状态可能位于不同的子任务中，并且这些子任务旨在独立运行，因此我想知道共享状态的最佳方式是什么。我能想到的一个解决方案是从子任务的侧输出创建一个键控数据流，并将其发送给正确的
-
问题内容： 创建一个Today小部件，我用来保留一些数据。在主应用程序中，我正在使用。这不能由扩展读取（或可以？），这就是为什么我使用构造函数。 用户在主应用程序中持久存储的数据需要在扩展程序中可用。 目前，我坚持两者，以便可以共享这些值 问题是我应该将它们放在一起并仅在我的应用程序中使用，还是这种不好的做法？ 编辑：我正在使用一个应用程序组容器。为了澄清起见，我问我是否应该在整个项目中用suit
-
问题内容： 假设我有一个要注入到config中的模块： 有两个子模块： 这是第一个： 第二个是相同的，以简化示例： 您会注意到，您可以将它们作为提供者来访问以配置选项： 如果我们在控制器中，则可以覆盖每个范围，例如： 但是，如果他们总是共享相同的财产怎么办？如何在提供商之间共享某些东西？ 我可以同时为和注入和配置共享属性吗？ 如何同时访问和作为单个模块的扩展？ 问题答案： 将模块插入两个共享这些属