腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(30)
视频
沙龙
1
回答
如果Flink作业下降,
StateTtlConfig
apache-flink
、
flink-streaming
我已经为一个分钟窗口运行聚合,并将
StateTtlConfig
配置为2分钟,类似于以下内容: .newBuilder(Time.minutes(2)) .setStateVisibility(
StateTtlConfig
.StateVisibility.NeverReturnExpi
浏览 4
提问于2022-07-25
得票数 0
1
回答
Flink在哪里存储计时器和State?
apache-flink
、
flink-streaming
OnTimerContext ctx, Collector<ValidationResult> out) state.clear();}{ public void open(Configuration parameters)
浏览 3
提问于2021-12-01
得票数 1
回答已采纳
2
回答
我们能更新一个州的TTL值吗?
apache-flink
、
rocksdb
我们有一个使用状态(ValueState和ListState)和TTL(
StateTtlConfig
)的拓扑结构,因为我们不能使用定时器(我们每天会生成数以亿计的定时器,而且它确实可以扩展:一个保存点/用一个新的
StateTtlConfig
(和更新的TTL时间)重新创建一个新的状态,并将CoProcessFunction的processElement1()和processElement2()方法中的值从
浏览 8
提问于2020-07-01
得票数 2
回答已采纳
2
回答
是整个MapState实例或MapState中每个元素的flink MapState的TTL
state
、
apache-flink
、
ttl
val ttlConfig =
StateTtlConfig
.setUpdateType(
StateTtlConfig
.UpdateType.OnCreateAndWrite) .build val
浏览 6
提问于2019-10-15
得票数 2
回答已采纳
1
回答
如果没有看到一个键,但是rocksdb有关于该键的状态,那么会发生什么情况?
apache-flink
、
flink-streaming
@Override { .newBuilder(Time.minutes(10)) .setSt
浏览 3
提问于2021-12-15
得票数 0
回答已采纳
1
回答
关于
StateTtlConfig
apache-flink
、
flink-streaming
、
flink-cep
我正在为
StateTtlConfig
配置MapState,我感兴趣的是进入状态的对象有3个小时的生命,然后它们应该从状态中消失并传递给GC来清理和释放一些内存,我认为检查点也应该释放一些重量。我以前有过这样的配置,似乎它没有起作用,因为检查点一直在成长:private final
S
浏览 3
提问于2020-08-24
得票数 1
1
回答
在MapState清理期间,Flink TTL清除映射键的整个值
apache-flink
、
flink-streaming
new MapStateDescriptor(
StateTtlConfig
ttlConfig =
StateTtlConfig
.newBuilder(Time.seconds(25)) .setState
浏览 3
提问于2020-03-18
得票数 0
1
回答
奇怪的"Cannot Serialize operator object class ...CoBroadcastWithNonKeyedOperator“错误
java
、
apache-flink
String> sideOutputTag = new OutputTag<String>("side-output") {};
StateTtlConfig
ttlConfig =
StateTtlConfig
.setUpdateType(
StateTtlConfig
.UpdateType
浏览 58
提问于2019-03-13
得票数 0
回答已采纳
1
回答
RichFlatMap中有无keyBy的状态管理
apache-flink
、
flink-streaming
ValueState<Boolean> valueState; public void open(Configuration parameters)
StateTtlConfig
ttlConfig =
StateTtlConfig
.setUpdateType(
StateTtlConfig
.UpdateType.OnCreateAndWrit
浏览 11
提问于2020-09-28
得票数 0
回答已采纳
1
回答
Flink是否支持BroadcastState的状态TTL?
apache-flink
BasicTypeInfo.INT_TYPE_INFO, ); .newBuilder(Time.seconds(3))
浏览 1
提问于2019-08-09
得票数 1
回答已采纳
3
回答
如何在Flink中为MapState中的所有项目设置TTL?
join
、
streaming
、
apache-flink
、
flink-streaming
我依赖于Flink解除对timers.Calculate的欺骗基于TTL (cleanup timestamp - current timestamp),使用
StateTtlConfig
为MapState
StateTtlConfig
是否适用于偶数时间处理?
浏览 10
提问于2021-02-19
得票数 1
回答已采纳
1
回答
当使用Rocksdb时,Flink ValueState将在过期后从存储中删除吗?
apache-flink
、
flink-streaming
、
rocksdb
下面是我的应用程序中的状态示例:
StateTtlConfig
ttlConfig =
StateTtlConfig
.setUpdateType(
StateTtlConfig
.UpdateType.OnCreateAndWrite) .setStateVisib
浏览 5
提问于2020-06-16
得票数 0
回答已采纳
1
回答
Flink是否可以处理其返回的键随时间变化的键选择器函数?
apache-flink
我们的想法是实现一个KeySelector,它将其输入对象映射到特定的分区键,但是这个键可以随着时间的推移而改变。例如,映射规则可以保存在数据库中,并且KeySelector将定期或按需更新它们。 我不确定这是否会对Flink的状态或流分区机制造成问题。例如,如果一个输入Foo最初映射到分区键0,但后来更改为分区键1,并且键0不再使用,那么Flink会在某个时候简单地“忘记”键0吗? Small Kotlin example.
浏览 18
提问于2019-06-03
得票数 0
1
回答
关于Flink中状态的TTL配置
apache-flink
、
flink-streaming
、
flink-cep
.; .setStateVisibility(
StateTtlConfig
.StateVisibility.ReturnExpiredIfNotCleanedUp
浏览 3
提问于2020-09-11
得票数 0
回答已采纳
1
回答
Flink重复数据消除和processWindowFunction
java
、
apache-flink
我正在创建一个管道,其中的输入是包含时间戳字段的json消息,用于设置eventTime。问题是一些记录可能会延迟到达或在系统中重复,这种情况需要管理;为了避免重复,我尝试了以下解决方案: .assignTimestampsAndWatermarks(new RecordWatermark() .keyBy(new MetricGrouper())
浏览 213
提问于2021-11-08
得票数 0
回答已采纳
1
回答
国家时间直播。它如何与Apache模式一起工作?
apache-flink
、
flink-streaming
、
flink-cep
1).newBuilder(Time.minutes(60)).setStateVisibility(
StateTtlConfig
.StateVisibility.NeverReturnExpired) //And use in my Process
浏览 4
提问于2020-10-03
得票数 0
回答已采纳
2
回答
使用ValueState的巨大检查点大小导致事件处理滞后
apache-flink
、
flink-streaming
ValueStateDescriptor<Boolean> desc;
StateTtlConfig
ttlConfig =
StateTtlConfig
.newBuilder(Time.milliseconds(cacheExpirationTimeMs)).setUpdateType(
StateTtlConfig
.UpdateType.OnCreateAndWri
浏览 5
提问于2022-05-16
得票数 0
1
回答
Flink的检查点随着时间的增加而增加
apache-flink
、
flink-streaming
、
flink-cep
看到检查站在7天内发生变化: public static final
StateTtlConfig
ttlConfig=
StateTtlConfig
.newBuilder(Time.hours(1)) .setStateVisibility(
StateTtlConfig</em
浏览 0
提问于2020-09-02
得票数 0
回答已采纳
1
回答
Apache 1.6.0 -
StateTtlConfig
和ListState
events
、
apache-flink
、
ttl
、
stateful
我在相应的
StateTtlConfig
上设置了一个ListStateDescriptor。 “所有状态集合类型都支持每个条目的TTL。这意味着list元素和映射条目将独立过期。”
浏览 2
提问于2018-08-30
得票数 1
回答已采纳
3
回答
如何解决状态大小小的慢检查点问题?
java-8
、
flink-streaming
我有一个flink应用程序(flink版本是1.9.2),它启用了检查点功能。当我在apache平台上运行时。我总是收到检查点失败的消息:在completing.After检查检查点期间threadDumps of taskManager之前,检查点过期了,我发现包含两个请求外部服务的操作符的线程总是处于可运行状态。下面是我设计的这个操作符和检查点配置。请帮助建议如何解决这个问题?public class OperatorA extends RichMapFunction<POJOA, POJOA> { private Connection connectio
浏览 3
提问于2020-07-03
得票数 3
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券