我的应用程序使用一个键控窗口，该窗口由时间戳函数键控。这意味着一旦触发并处理了该特定窗口，就没有必要保持该键处于活动状态，因为该特定键不可能再次出现。因为这个用例涉及到不断扩展键，所以我希望在键完成处理后立即清除它的状态，而不必配置计时器。 在每个键控窗口完成处理后，这是否可以在evictor方法或apply方
浏览 24提问于2019-02-14得票数 0
回答已采纳
在键控流上，我希望在新事件到达时立即计算每个新传入事件一次窗口函数，同时作为迭代器在过去30天内为其提供此键的所有早期事件的上下文。预期的行为类似于滑动窗口的30天长度和1纳秒的幻灯片，计算窗口功能只计算一次每次传入事件。有人能帮忙吗？还是需要编写我自己的窗口分配程序或我自己的键控状态<
浏览 0提问于2016-11-04得票数 5
回答已采纳
据我所知，窗口是这个场景的完美匹配。我使用键控状态来跟踪window encounteredElementsCountState中的元素计数
在接收
浏览 0提问于2019-07-26得票数 0
我有一个时间窗口，我试图确定我是否在一段时间内得到了一个新的密钥。我正在通过kafka推送数据，当我调试它时，我看到数据正在到达keyby方法，但是它没有到达process方法，也没有被收集器收集。
浏览 4提问于2020-02-19得票数 0
回答已采纳
存储在数据库中的模板如描述的，然后编辑和持久化，在不清除缓存的情况下，即使在dev模式下，也不能呈现以供审阅。清除缓存后，模板将保持固定状态，直到再次清除缓存为止。大概有一种方法允许这样一个编辑过的模板立即可用，而不必清除缓存？
浏览 2提问于2014-07-03得票数 1
回答已采纳
对于每个键，我希望创建一个事件时会话窗口，并仅在以下情况下对其执行一些处理：对于每个键，MIN_EVENTS是不同的，在运行时可能会发生更改apply(new MyProcessFn())
我正在尝试创建一个自定义MyCustomCountTrigger()，它应该能够从状态存储区(如MapState<String, Integer> stateStore我知道我可以使用所有触发器都可用的T
浏览 7提问于2020-02-03得票数 0
回答已采纳
我只是想了解在Flink中使用CoProcessFunction的用例。举例说明会帮助我更好地理解这个概念。
浏览 21提问于2019-07-28得票数 1
回答已采纳
我注意到，当服务器获得更多请求(如340mb、410mb、422MB…)时，内存使用量会随着负载的增加而增加，然后它会自动下降到正常状态(230mb)。但当服务器收到更多请求时，内存使用量会持续增加，即使在CPU使用率达到正常阶段后，也无法释放未使用的内存，最终达到最大值(512mb)并崩溃。如果它正确地清除了未使用的内存/资源，我们就可以避免这种情况。JVM应该使用垃圾收集器自己处理内存使用情况。但是一旦请求被处理，它就无法清除不需要的内存(对象)。我使用下
浏览 0提问于2017-05-08得票数 1
我的flink作业有keyBy操作符，它以date~clientId(日期为yyyymmddhhMM，MM为分钟，5分钟后更改)为关键字。此操作符之后是5分钟的翻滚窗口。下面是我的疑虑：
3)窗口大小对检查点时间的影响。
4)在任何5分钟内不同客户的数量增加5-10倍的场景中，会有什么影响。这会造成数据失真吗？
浏览 1提问于2020-03-12得票数 0
我们正在从Kinesis中读取数据，并写入到parquet中，我们使用StateSpec<ValueState<Boolean>>来避免在优雅地停止并从最后一个保存点重新启动我们的流水线后重复处理记录。我们正在处理如何在每个特定时间清除状态，而不会有丢失最近处理的记录的风险，如果在即将到来的停止中需要这些记录。(也就是说，我们需要一个类似于TTL的类)。我们考虑了一个每隔一段时间清除状态的计时器，但这并不符合我
浏览 20提问于2021-02-24得票数 0
回答已采纳
我在这里读到了有关flink`s的窗口赋值器的文章：https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators作为我的项目的一部分，我需要一个窗口，即计时器将启动给关键的第一个元素，并将被关闭，并设置为X分钟后的处理准备。例如： 第一个keyA出现在(hh:mm:ss) 00:00:02，我希望所有的keyA都是窗口，直到00:01:0
浏览 27提问于2019-12-24得票数 0
在弗林克有什么办法在特定时间清理状态吗？例如，我需要在每天0:00更新状态。有些元素来得更早，有些则更晚。但是，所有这些都应该在一天结束时被抹去。是否提供API某种调度机制来做到这一点？或者如何在最坏的情况下手动清理整个操作符状态？
浏览 20提问于2022-10-20得票数 0
回答已采纳
我已经在一个流中输入了关键事件，我希望按键累积，直到超时(例如，5分钟)，然后处理累积到那个点的事件(然后忽略该键之后的所有内容，但首先是第一件事)。如何在Flink中完成键控窗口超时？
浏览 0提问于2018-12-05得票数 1
回答已采纳
1回答
我知道如何在延迟后暂停使用：然而，这似乎只有当我保持控制台窗口打开时才能工作。当我关闭控制台时，我是否正确地假定at命令已被清除？
这是一个问题，因为我希望能够通过SSH登录到我的计算机，发送挂起命令，然后在发生之前注销。立即挂起会冻结我的本地控制台窗口，这是不方便的。是否有一种方法可以在我注销时发送延迟挂起命令而不清除它？
浏览 0提问于2012-10-11得票数 2
回答已采纳
1回答
我们在很大程度上依赖于具有reduce功能的时间窗口和键控数据。我们的tps目前在100-200左右。我有几个关于检查点和保存的状态大小的问题: 1.由于我们使用的是reduce函数，状态大小是否只受打开的窗口数量的影响？如果每小时窗口和分钟窗口都有相同的累加器，我们是否应该期望类似的状态大小？由于某种原因，我们看到每小时窗口的状态比分钟窗口大得多，而每天窗口的状态</em
浏览 46提问于2019-05-03得票数 1
1回答
我正在使用'Colorbox‘()jQuery插件来显示模式窗口。其中一个模式窗口是登录窗口。它将一个外部登录页面加载到模式窗口中。如何在登录并关闭登录模式窗口后</em
浏览 1提问于2011-07-31得票数 2
回答已采纳
我遇到的问题是，当我在批处理文件中运行命令时，它会打开另一个控制台窗口，显示结果不到一秒钟，然后再次关闭。我希望命令的结果(devcon状态)显示在该窗口中，类似于“暂停”选项。devcon enable *REV_7869devcon status *REV_7869exit
当我输入"Check“时，它将打开另一个控制台窗口，正确运行devcon status命令，但当有结果时立即关闭窗口。然而
浏览 2提问于2013-08-21得票数 4
假设我有一个由(user_id, location)键控的流A，以及一个流B，它被广播给所有执行者，以便使用我定义的类处理A中的元素。例如，在流A中，(user_id=1, location='usa')提供了一条新消息，并且生成了这样的密钥组及其关联状态。比如说，24小时后，我对这个密钥组(user_id=1, location='usa')不再感兴趣了，我可以注册一个定时器来清除关联的状态，但是我无法控制这个密钥组。因此，24小时后</
浏览 0提问于2019-01-08得票数 1
我想知道如何在我的游戏中处理RPC数据包的丢包问题。例如，如果客户端正在向前移动，但过了一段时间就开始清除，但是由于丢包而丢弃了strafe RPC(MovingLeft)。服务器仍然会认为玩家正在前进，但是客户端的预测会使玩家在按下'A‘键后立即向左扫射。
您应该让客户端在过去的一段时间内覆盖服务器权限吗？如果客户端正在修改服务器上的过去状态，这将如何影响服务器模拟？
浏览 0提问于2018-03-29得票数 0
回答已采纳
1回答
我们将立即显示新窗口，显示状态为挂起，但在后台，所有的pdf应该被合并，如果合并结束，状态应该被更改为可用。 如何在web应用程序中实现发送响应后的后台进程，以及后台进程完成后再次发送响应
浏览 11提问于2019-05-28得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
