包含标签：flink 的文章
-
flink学习之state
state作用 保留当前key的历史状态。 state用法 ListState<Integer> vipList = getRuntimeContext().getListState(new ListStateDescriptor<Integer&……admin 2023-09-14
-
Flink JobManager的高可用配置
背景 在flink执行中，jobManager是一个负责执行流式应用执行和检查点生成的组件，一旦发生故障，那么其负责的所有应用都会被取消，所以我们需要对JobManager…… -
dinky+flink+doris实时架构全流程demo
一、版本 doris：doris-1.2.3-rc02 flink：flink1.4.6 dinky：0.7.2 jdk：1.8.0_191 mysql：5.7 二、安装doris 官网下载地址：https://archive.apache.org/di…… -
如何处理 Flink 作业频繁重启问题？
分析&回答 Flink 实现了多种重启策略 固定延迟重启策略（Fixed Delay Restart Strategy） 故障率重启策略（Failure Rate Restart Strategy） 没有重启策…… -
flink 部署模式和运行时架构（会话模式、单作业模式、应用模式，JobManager、TaskManager，YARN 模式部署以及运行时架构）
文章目录 1. 部署模式（抽象的概念） 1.1 会话模式（Session Mode） 1.2 单作业模式（Per-Job Mode） 1.3 应用模式（Application Mode） 1.4 总结 2.…… -
flink维度表关联
分析&回答 根据我们业务对维表数据关联的时效性要求，有以下几种解决方案： 1、实时查询维表 实时查询维表是指用户在Flink 的Map算子中直接访问外部数据…… -
Flink之Watermark
1.乱序问题 流处理从事件产生，到流经source，再到operator，中间是有一个过程和时间的，虽然大部分情况下，流到operator的数据都是按照事件产生的时间顺序来…… -
说说Flink on yarn的启动流程
分析&回答 核心流程 FlinkYarnSessionCli 启动的过程中首先会检查Yarn上有没有足够的资源去启动所需要的container，如果有，则上传一些flink的jar和配…… -
【Flink】Flink架构及组件
我们学习大数据知识的时候，需要知道大数据组件如何安装以及架构组件，这将帮助我们更好的了解大数据组件 对于大数据Flink，架构图图下： 整个架构图有三种…… -
Flink状态的理解
Flink是一个带状态的数据处理系统；系统在处理数据的过程中，各算子所记录的状态会随着数据的处理而不断变化； 1. 状态 所谓状态State，一般指一个具体的 Ta……