Apache Flink窗口允许的无限延迟
我有以下用例，如果有明显的解决方案，很抱歉，但我对Flink非常陌生：
谢谢
共有1个答案
通常，允许的迟到需要是有限的，以避免保持无界量的状态。但是您可以将Flink配置为使用RocksDBStateBackend，这会将状态溢出到磁盘，从而允许本地磁盘能够容纳的状态。
如果非常晚的事件很少发生，您最好以某种特殊的方式来处理它们，而不是用所有状态的开销来负担通用管道。
-
我有以下代码来计算socketTextStream中的单词。累积字数和时间窗字数都是必需的。该程序存在累积计数始终与窗口计数相同的问题。为什么会出现这个问题？根据加窗计数计算累积计数的正确方法是什么？
-
我试图允许调整这个应用程序的大小，我把可调整大小的标志，但当我试图调整大小，它搞砸了！试试我的代码。 这是一个网格程序，当窗口调整大小时，我希望网格也调整大小/缩小。 请告诉我怎么了，谢谢。
-
在中，元素被分配给一个或多个实例。在滑动事件时间窗口的情况下，这发生在1中。 如果窗口的和，则将时间戳为0的元素分配到以下窗口： 窗口（开始=0，结束=5） 窗口（开始=-1，结束=4） 窗口（开始=-2，结束=3） 窗口（开始=-3，结束=2） 窗口（开始=-4，结束=1） 在一幅图片中： 有没有办法告诉Flink时间有开始，而在那之前，没有窗户？如果没有，从哪里开始寻求改变？在上述情况下，Fl
-
问题内容： 我正在创建一个使用webpack-dev-server和react-router进行开发的应用程序。 似乎webpack-dev-server是建立在以下假设的基础上的：您将在一个位置拥有一个公共入口点（即“ /”），而react- router允许无限数量的入口点。 我想要webpack-dev-server的好处，特别是对生产力非常有用的热重载功能，但是我仍然希望能够加载react
-
我很难理解水印和允许迟到的概念。 以下是[邮件存档]的摘录|https://www.mail-archive.com/user@Flink。阿帕奇。组织/msg08758。html]这谈到了水印，但我还有几个问题。以下是引用的示例： 假设您有一个，具有2分钟的绑定和10分钟的翻转窗口，从12:00开始到12:10结束： 如果您具有以下流序列： 不允许迟到 当窗口操作符接收到<代码> 允许迟到3分钟
-
如何在ApacheFlink中为会话窗口分配id？ 最后，我希望在会话窗口打开时，使用会话窗口id逐个充实事件（我不希望等到窗口关闭后再发出充实事件）。 我尝试使用AggregateFunction来实现这一点，但是我认为merge（）并没有像我所期望的那样工作。它似乎是用于合并窗口而不是窗格（触发触发）。在我的管道中似乎从未调用过它。因此，触发器之间似乎没有共享状态！ 会话窗口ID将是落入窗口的