我使用的是翻滚窗口(5分钟)和AscendingTimestampExtractor，因为我的源码来自Kafka。但是窗口的运行时间总是超过5分钟。有没有人能建议一下？
浏览 13提问于2020-02-25得票数 0
我感兴趣的是获得翻滚窗口触发器的实际运行开始时间。我不想要日程安排触发器。我的场景需要特别的翻滚窗口触发器，但一些逻辑也需要确切地知道触发的运行开始的时间。根据我尝试使用@pipeline().TriggerTime的，基本上我将它作为值传递给一个管道参数，但随后它没有转换为值--然后我意识到这个表达式的作用域在管道中，所以我不能在触发器中使用它。@ trigger ().outputs.windo
浏览 7提问于2019-11-23得票数 0
由于重试策略，我们需要使用翻滚窗口触发器，但我们的prod部署将在开发部署1个月后进行，我们不想在生产中手动终止这30个执行，因为翻滚窗口触发器的功能可以运行那些错过的天数。有没有办法避免这种情况？
浏览 1提问于2021-01-14得票数 0
我想在Flink中创建一个基于EventTime的会话窗口，这样当新消息的事件时间比创建窗口的消息的事件时间长180秒时，它就会触发。This message, and all subsequent messages have to be ignored as this window was processed at t7 我想创建一个触发器，以便通过适当的水印或onEventTime触发器来实现上述行为。
浏览 13提问于2019-03-25得票数 0
key).process(computeLogic)
.sink(sinkFunction) 我的问题是： 如果我有太多的关键点，假设超过10,000个关键点，每个关键点会有一个窗口吗
浏览 55提问于2020-12-15得票数 0
回答已采纳
我正在尝试创建一个滚动窗口，触发，以便在管道开始执行之前每1小时运行一次和10分钟延迟。我在管道的Monitor部分实际看到的是运行和触发器，它每5分钟运行一次。我在这里做错什么了吗？更新的{
"name":
浏览 3提问于2021-07-25得票数 0
rowtime, name, duration " + table);那么，如果我尝试在带有时间窗口(翻滚等)的SQL查询中使用它，它将如何工作，这是否受到尊重？但是我假设延迟的事件将被删除，并且我可以使用我的rowtime作为翻滚窗口的属性？
浏览 47提问于2020-02-14得票数 1
我使用以下命令将水印生成频率设置为2秒： env.getConfig().setAutoWatermarkInterval(2000); 现在，对于流窗口，我的翻滚窗口是60秒，其中我们进行了一些聚合，然而，由于我们做的是翻滚窗口，即没有重叠，我猜没有30-90窗口，0-60之后的下一个窗口是60-120，在150秒触发，对吗？Q.2如果没有allowedLateness，所有延迟的数据将被丢弃，例如。在90秒后到达
浏览 33提问于2021-07-08得票数 0
回答已采纳
到目前为止，我一直在使用每小时运行一次的“事件”触发器，它很好。但不知何故，负载开始运行了一个多小时。因此，下一次加载将在前一次加载仍在运行时开始。我一直在尝试使用“翻滚窗口”触发器来创建对此管道的自我依赖，以便它在运行之前等待前一个管道完成，但无法使其工作。
如果有人对如何解决这个问题有一些经验，任何见解都将不胜感激。
浏览 1提问于2020-10-14得票数 0
下面是代码片段，其中我使用了一个基于EventTime的翻滚窗口 public static class TimestampExt
浏览 0提问于2017-06-29得票数 0
我不得不禁用OnEraseBkgnd()，并且只使用OnPaint()。像使用后台缓冲区这样的技术不是一种选择。
浏览 2提问于2009-05-24得票数 2
回答已采纳
1回答
使用翻滚的窗口触发器。如果管道成功，则应继续每一小时运行一次。如果管道由于某种原因而失败，下一个实例，我的意思是管道不应该在下一个小时内运行。
如果管道失败，我们如何停止触发。
浏览 8提问于2022-04-05得票数 0
我使用会话窗口，对于course.But，似乎每个键都有重叠的窗口。我在网上搜索过却不知道为什么。# timestamp equals to 2019-05-29 19:22:24.844
我有一个2019-05-29 19:22:22.605- 2019-05-29 19:23:22.605窗口数据是myform(1559128942, 123, kid, 37890, begin)，然后是2019-05-29 19:22:22.605 - 2019-05-29 19:23:24.844的第二个窗口
浏览 0提问于2019-05-29得票数 0
回答已采纳
我想使用Flink的事件时间戳，并计划实现一个简单的emitWatermark，即System.currentTimeInMillis - 10秒。我的理解是翻滚窗口会触发start_time + window_interval +10秒。因此，如果事件到达的时间晚于水印，那么这些事件将被删除。
浏览 0提问于2018-04-13得票数 2
打开安卓摄像头时，必须设置SurfaceHolder或OpenGL SurfaceTexture来保存显示的图像，分别使用setPreviewDisplay() (API级别1)或setPreviewTexture
浏览 0提问于2013-05-26得票数 12
回答已采纳
数据通过pubsub有各种延迟，但我不想因为时间偏差或数据延迟而延迟窗口触发。也就是说，我只想处理触发时可用的数据，并希望基于墙时间触发(但每个窗口应包含基于数据事件时间的[触发时间-M小时，触发时间)之间的数据。)我正在尝试使用SlidingWindows，但触发是基于事件时间的，并且似乎由于数据延迟而延迟。谢谢,
浏览 1提问于2016-11-08得票数 2
1回答
是否可以从Flink流作业触发检查点？问题是我的状态很大，一个常规的周期性检查点有时会花费太多时间。但无序意味着我已经在未来的窗口中从当前偏移量中获得了一些数据。所以我需要检查点。
如果可以在窗口清理后触发检查点，而不是定期触发检查点，那么效率会更
浏览 1提问于2017-07-19得票数 2
我使用的管道如下：connect(configurationBroadcastStream).process(new CustomProcessWindowFn())
浏览 2提问于2020-02-27得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号