如何在Flink流中执行空窗口上的函数？
共有1个答案
我也遇到了同样的情况。用另一个进程填补数据库中的漏洞是一种解决方案。
但是，我发现将您的主流与一个自定义的定期源联合起来会更容易，该源会发出假人，假人的唯一作用是触发windows创建。在执行此操作时，您必须确保在计算中忽略假人。
下面是如何编写一个定期源代码（但是您可能不需要RichParallelSourceFunction，一个SourceFunction就足够了）
-
下面是目前为止我所想到的伪代码。任何帮助都将不胜感激！谢谢！ 我检查了Table API，但对于流，似乎不支持很多操作，例如OrderBy。
-
我正在尝试使用主题列表中的单个kafka使用者组合两个kafka主题，进一步将流中的json字符串转换为POJO。然后，通过keyBy（On事件时间字段）将它们加入，并将它们合并为单个胖json，我计划使用窗口流并在窗口流上应用窗口函数。假设主题A 我有几个问题。 这种方法适合合并主题并创建单个JSON吗 所有窗口流上的窗口函数似乎工作不正常；任何指点都将不胜感激 代码片段: 我得到了- AllW
-
下面是代码片段，我在其中使用了基于翻滚事件时间的窗口 不幸的是，它似乎从未执行过reduce函数。如果使用上面的代码进行窗口处理，reduce函数可以正常工作。下面是时间戳提取器的代码。30秒水印延迟仅用作测试值，但一分钟翻转窗口为m bd.longValue()，它返回秒时间戳1498658629，因为我的窗口也是以秒为单位定义的。< br >当我使用返回分钟时间戳的bd.longValue()
-
我有一些问题。 基于类中的时间戳，我想做一个逻辑，排除在1分钟内输入N次或更多次的数据。 UserData类有一个时间戳变量。 起初我试着用一个翻滚的窗户。 但是，滚动窗口的时间计算是基于固定时间的，因此无论UserData类的时间戳如何，它都不适合。 如何处理流上窗口UserData类的时间戳基？ 谢谢。 附加信息 我使用这样的代码。 我试了一些测试。150个样本数据。每个数据的时间戳增加1秒。
-
我的目标是杀死Flink任务管理器，然后在Windows上重新启动它。这是刺激Flink中的错误所必需的，这样我就可以看到检查点的工作。我已经设法找到了任务管理器PID通过查找PID对它侦听的端口。所以杀死PID应该杀死taskManager，但是我找不到在windows上重启Flink taskManager的方法，因为taskManager脚本是一个外壳脚本。请帮助我在以下两个问题。 如何在W