Apache Flink-如何在启动时跳过除最新窗口以外的所有窗口
在Flink有可能吗？如果是的话，那该怎么做呢？
共有1个答案
您可以使用
FlinkKafkaConsumer<T> myConsumer = new FlinkKafkaConsumer<>(...);
myConsumer.setStartFromTimestamp(...); // start from specified epoch timestamp (milliseconds)
该功能与其他相关功能一起在文档中关于Kafka消费者开始位置配置的部分中进行了描述。
或者，您可以使用保存点进行干净的升级/重新部署，而不会丢失kafka偏移量和相关的窗口内容。
-
我的目标是杀死Flink任务管理器，然后在Windows上重新启动它。这是刺激Flink中的错误所必需的，这样我就可以看到检查点的工作。我已经设法找到了任务管理器PID通过查找PID对它侦听的端口。所以杀死PID应该杀死taskManager，但是我找不到在windows上重启Flink taskManager的方法，因为taskManager脚本是一个外壳脚本。请帮助我在以下两个问题。 如何在W
-
在中，元素被分配给一个或多个实例。在滑动事件时间窗口的情况下，这发生在1中。 如果窗口的和，则将时间戳为0的元素分配到以下窗口： 窗口（开始=0，结束=5） 窗口（开始=-1，结束=4） 窗口（开始=-2，结束=3） 窗口（开始=-3，结束=2） 窗口（开始=-4，结束=1） 在一幅图片中： 有没有办法告诉Flink时间有开始，而在那之前，没有窗户？如果没有，从哪里开始寻求改变？在上述情况下，Fl
-
如何在ApacheFlink中为会话窗口分配id？ 最后，我希望在会话窗口打开时，使用会话窗口id逐个充实事件（我不希望等到窗口关闭后再发出充实事件）。 我尝试使用AggregateFunction来实现这一点，但是我认为merge（）并没有像我所期望的那样工作。它似乎是用于合并窗口而不是窗格（触发触发）。在我的管道中似乎从未调用过它。因此，触发器之间似乎没有共享状态！ 会话窗口ID将是落入窗口的
-
我写了一个小GUI程序与python在tkinter的窗口。我的窗口必须在全屏游戏窗口的前面。 此刻，我用这句话： 它适用于普通窗口（浏览器，浏览器，...），但如果我启动游戏到全屏模式，我的窗口隐藏在游戏后面。 为什么会发生这种情况？调用游戏可能类似于覆盖我的属性的？ 我的问题还有别的解决办法吗？也许可以告诉windows，我的窗口应该在特定窗口（游戏窗口）的前面？
-
问题内容： 我在应用程序中使用selenium+ phantomjs，但我想在后台启动我的应用程序，selenium和phantomjs窗口。我该怎么做？ 我试过了： 问题答案：
-
我有以下代码来计算socketTextStream中的单词。累积字数和时间窗字数都是必需的。该程序存在累积计数始终与窗口计数相同的问题。为什么会出现这个问题？根据加窗计数计算累积计数的正确方法是什么？