当前位置: 首页 > 知识库问答 >
问题:

Flink-手动删除关键帧

邹坚壁
2023-03-14

我们有一个键控流程函数,它使用状态和在此之前立即执行的“key by”。“key by”属性涉及事务值,因此我们希望创建许多键。但这些都是短期的,我们预计不会持续超过一天。是否有任何方法可以从键控流程功能中手动删除与键关联的所有状态和键本身?

只需将关联状态变量的值设置为null,Flink就能清除它吗?

我们担心,即使是为每个关键值保留的非常少量的剩余数据,也会累积并导致巨大的状态大小。

共有1个答案

薛欣荣
2023-03-14

一种解决方案是配置状态TTL,以便在一段时间未使用后自动删除状态。或者您可以在键控进程函数中注册一个键控计时器,并在onTimer方法中调用Clear()以在计时器触发时删除状态。

 类似资料:
  • 本文向大家介绍Oracle中手动删除数据库教程,包括了Oracle中手动删除数据库教程的使用技巧和注意事项,需要的朋友参考一下 在很多情况下,或无法使用dbca工具的时候,我们需要手动来删除数据库。对此,可以借助drop database命令来实现,下面的描述中给出手动删除数据库。 的具体步骤,包含文件系统数据库以及ASM数据库。环境:Oracle Enterprise Linux 5.4 + O

  • 什么是关键帧? 关键帧用于设置动作、效果、音频以及许多其他属性的参数,这些参数通常随时间变化。关键帧标记您为图层属性(如空间位置、不透明度或音量)指定值的时间点。可以在关键帧之间插补值。使用关键帧创建随时间推移的变化时,通常使用至少两个关键帧:一个对应于变化开始的状态,另一个对应于变化结束的新状态。 当某个特定属性的秒表处于活动状态时,如果您更改该属性值,After Effects 将自动设置或更

  • 在Cassandra中,“”命令用于从Cassandra中删除所有数据,列族,用户定义的类型和索引的键空间。 Cassandra在删除键空间之前,先获取键空间的快照。 如果Cassandra中不存在keyspace,Cassandra将返回错误,除非使用关键字。 语法 示例: 我们举一个例子来删除名为“”的键空间(keyspace)。 验证: 在执行上述命令后,从Cassandra中删除键空间“”

  • 问题内容: 我有一个表X,该表具有一个自动递增的ID列作为其主键。我还有其他表A,B,C和D,它们补充了表X中的信息。每个表都必须包含一个引用表X中ID的列。我已经这样做了,并且在我的代码(Java)中,将每个条目的ID返回到表X并在插入其他表时使用该ID的方法。一切都很好。 现在,建议我将表A,B,C和D上的ID列分配为FOREIGN KEYS,因为“这是正确的做法”。我做到了 现在,从表X中删

  • 问题内容: 我将quartz.net版本从1.0.3升级到2.0.2。有一个用于数据库模式的迁移脚本,该脚本是为MSSQL编写的,并且我正在尝试为其编写MYSQL版本。 但是,我无法删除主键(需要这样做)。 MSSQL的原始脚本版本: 为了简单起见,我正在尝试第一个声明 这是我尝试过的结果: ALTER TABLE BLOB_TRIGGERS DROP PRIMARY KEY; [Err] 102

  • (警告:我不是MySQL专业人士,我使用工作台代替知道命令,所以我的问题可能很简单) 我试图重命名表(user)中的主键(userID),但MySQL不允许(错误号150)。经过一番挖掘,我似乎必须先删除外键,然后才能重命名主键。 因此,在Workbench中,我转到下一个表(问题)并选择alter table,然后转到外键选项卡。我在左侧窗口中选择唯一的外键(fk\u question\u us