腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(6211)
视频
沙龙
1
回答
如何解决进程函数中的繁忙时间问题?
、
我有一个无界流的
flink
(v1.13.3)应用程序(使用kafka)。我的一条小溪很忙。而且繁忙值(我可以在UI上看到)随着时间的推移而增加。当我刚启动
flink
应用程序时: sum by(task_name) (
flink
_taskmanager_job_task_busyTimeMsPerSecond{job="
Flink
", task_name="MyProcessFunction"})返回300-450 ms five++ hours sum by(task_name) (
浏览 18
提问于2022-01-12
得票数 1
回答已采纳
1
回答
初始化Sate会导致"java.lang.NullPointerException:键控状态只能用于‘键控流’“
、
、
、
我试图在
ListState
中初始化一个“CoProcessFunction”,但是它总是抛出这个错误“java.lang.NullPointerException:键控状态只能在‘键控流’上使用”。stream1
ListState
; @Override public void open(Configuration parametersString>>("type1",TypeInformation.of(new TypeHint<Tuple2<
浏览 7
提问于2021-03-11
得票数 0
回答已采纳
1
回答
Flink
kafka连接器和
flink
版本
、
说我们不应该同时升级
Flink
和Kafka连接器版本。 但是我不能用旧版本的卡夫卡连接器与更新的
Flink
。我尝试使用
Flink
-连接器-kafka-010 1.10.2和
Flink
1.14,并获得异常:java.lang.NoSuchMethodError: org.apache.
flink
.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apach
浏览 12
提问于2022-08-31
得票数 0
回答已采纳
1
回答
Flink
的窗口操作是处理窗口末尾的元素,还是做滚动处理?
、
我有一些困难,了解窗口是如何在内部实现
Flink
,并没有找到任何文章,以解释这一点的深入。在我看来,有两种方法可以做到。是否有人能帮助您理解
Flink
在现实中使用的方法(或者可能是不同的方法)。原因是,这两种方法各有优缺点,为了正确配置集群的资源,理解这两种方法是很重要的。
浏览 6
提问于2022-01-17
得票数 0
回答已采纳
2
回答
Apache
Flink
进程函数状态不是保持状态
、
、
、
我正在为Apache
Flink
1.4中的processElement函数编写一些代码: public class ProcessFunctionClass extends ProcessFunction<Tuple2<String, String>, Tuple2<String, String>>{ publicCollector<Tuple2<String, String>&g
浏览 20
提问于2020-06-21
得票数 0
2
回答
使用
Flink
同步的进程2流
、
、
、
、
这可以在
Flink
中实现吗?
浏览 48
提问于2021-01-21
得票数 0
1
回答
Flink
可查询状态错误
、
我试图在
Flink
(1.4.2版)上使用可查询状态,但不幸的是,我一直收到以下错误: at org.apache.
flink
.queryablestate.network.ClientHandler.channelReadmyEvents", typeInform
浏览 5
提问于2018-05-18
得票数 0
1
回答
Apache检查(手动将一个值放入RocksDB检查点并在恢复或重新启动期间检索)
、
、
我们有一个场景,在这个场景中,我们必须将一些值保存到检查点中,并在故障恢复/应用程序重新启动期间将其检索回来。
浏览 10
提问于2022-01-19
得票数 0
2
回答
全局窗口自定义触发器上的allowedLateness
、
、
、
我已经为我的事件流创建了一个自定义触发器和处理函数。 sensorEvents .window(GlobalWindows.create()) .allowedLateness(Time.minutes(1)) # Note .process(new MyCustomWindowProcessFunction())
浏览 3
提问于2020-02-19
得票数 1
回答已采纳
1
回答
Flink
-如何在状态下聚合
、
我有一个keyd数据流,看起来像这样: { uid:String ..... } 我需要聚合某个时间范围内的汇总值,一旦我达到了一个特定的数字,就将摘要和所有影响摘要的UID刷新到数据库/日志文件中。 在第一次刷新之后,我想从内存中清除所有的uid,并立即刷新每个新项。 所以我尝试了这个聚合函数。 public class AggFunc implements AggregateFunction<Item, Acc, Tuple2<Integer,
浏览 16
提问于2020-08-24
得票数 0
1
回答
在我的简单应用程序中未创建任何检查点文件
我在集成开发环境中运行了以下简单的
flink
应用程序,并且每隔5秒执行一次检查点操作,并希望将检查点数据写入目录file:///d:/applog/out/mycheckpoint/,但在运行了一段时间后{
ListState
, ListStateDescriptor}import org.apache.
flink
.runtime.state.filesystem.FsStateBa
浏览 20
提问于2019-09-26
得票数 0
回答已采纳
1
回答
Flink
共享状态和种族条件
嘿,我很难理解共享状态(ValueState,
ListState
,.)在弗林克工作。如果一个任务的多个实例并行运行,那么
flink
如何防止竞争条件?在这个来自的例子中,如果操作符是并行的,那么
flink
如何保证在读取和更新keyHasBeenSeen值之间没有竞争条件?
浏览 14
提问于2022-11-04
得票数 0
回答已采纳
1
回答
基于存储对象属性的
flink
状态剪枝
、
、
、
考虑下面的示例类,该类的实例存储在
ListState
中 long clientId; Instant lastDealDate; }怎样才能让
flink
知道这两个因素,从而自动删除这些条目呢?之所以使用
ListState<
浏览 4
提问于2020-11-05
得票数 0
回答已采纳
1
回答
对intervalJoin感到困惑
、
、
Flink
是这个用例的正确选择还是我完全错了?
浏览 2
提问于2021-03-25
得票数 0
回答已采纳
1
回答
升级Apache需要更新pom.xml吗?
我刚刚将我的
flink
从1.9.1升级到1.11.2 (使用docker) --当我尝试升级到1.11.1并重新运行我的作业时,已经有许多
flink
作业在1.9.1版本中运行,它会显示错误。ERROR org.apache.curator.ConnectionState [] - Authentication failed由:未定义的java.lang.RuntimeException: API路径引起 org.apache.
fl
浏览 5
提问于2020-11-11
得票数 0
回答已采纳
2
回答
Bootstrap闪烁状态
、
、
我正在做一个简单的聚合,它对给定资源上发生的事件的总数进行求和(参见:)。在一些帮助下,我让它工作了,但现在我遇到了另一个问题。本质上,我想以某种方式从遗留系统中引导状态(加载昨天的统计数据),然后在此基础上加入来自kinesis流的今天的数据,并在此过程中避免重复。理想情况下,这是一个一次性的过程,应用程序应该从kinesis开始运行。谢谢
浏览 4
提问于2018-04-05
得票数 4
1
回答
原始状态与托管状态的示例
托管状态以
Flink
运行时控制的数据结构(如内部哈希表或RocksDB )表示。例如“ValueState”、“
ListState
”等。
Flink
的运行时对状态进行编码,并将它们写入检查点。
Flink
对状态的数据结构一无所知,只看到原始字节。 然而,我没有发现任何突出区别的例子。有人能提供一个最小的例子来使代码中的差异变得清晰吗?
浏览 2
提问于2019-11-30
得票数 0
回答已采纳
1
回答
在
flink
中,检查点不使用dynamodb流记录
、
这是代码import org.apache.
flink
.api.common.state.ListStateDescriptor;import org.apache.
flink
.api.java.tuple.Tuple
浏览 6
提问于2022-05-24
得票数 0
3
回答
Flink
上限MapState
背景
Flink
是否提供了一个API来限制状态中元素的数量? 使用MapState和StateTtlConfig生成的TTL/过期机制。
浏览 4
提问于2022-04-07
得票数 1
回答已采纳
2
回答
在
Flink
中按顺序读取两个流(主流和信任流)
、
但是,当
flink
第一次启动时,当我们添加作业时,它开始从事务中消费,并并行地信任流;当需要进程事务时,它有时会看到没有配置,我们不得不将事务发送到死信队列。长话短说,是否有办法告诉
flink
,当第一次作业开始尝试消耗一个流,直到没有新的值,然后开始处理主流流?我怎么能把它们按顺序排列呢?
浏览 13
提问于2022-04-14
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
大数据入门:Flink状态编程与容错机制
Flink基础教程(二):初探Flink
Flink CDC 如何与其他 Flink 特性集成?
Flink 支持哪些状态管理方式?
Apache Flink 进阶(六):Flink 作业执行深度解析
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券