flink

【flink理论】动态表：关系查询处理流的思路：连续查询、状态维护；表转换为流需要编码编码

Byroman_日积跬步-终至千里2023年11月18日

文章目录一. 使用关系查询处理流的讨论二. 动态表 & 连续查询(Continuous Query)三. 在流上定义表1. 连续查询2. 查询限制2.1. 维护状态2.2. 计算更新四. 表到流的 ...

ByMeepoljd2023年11月18日

Flink任务缺失Jobmanager日志的问题排查问题不是大问题，不是什么代码级别的高深问题，也没有影响任务运行，纯粹因为人员粗心导致，记录一下排查的过程。问题描述一个生产环境的奇怪问题，环境 ...

By一瓢一瓢的饮 alanchan2023年11月18日

Flink 系列文章 1、Flink 部署、概念介绍、source、transformation、sink使用示例、四大基石介绍和示例等系列综合文章链接 13、Flink 的table api与sql ...

By一瓢一瓢的饮 alanchan2023年11月18日

Flink 系列文章 1、Flink 部署、概念介绍、source、transformation、sink使用示例、四大基石介绍和示例等系列综合文章链接 13、Flink 的table api与sql ...

By猫猫爱吃小鱼粮2023年11月06日

1.滚动窗⼝（TUMBLE） **滚动窗⼝定义：**滚动窗⼝将每个元素指定给指定窗⼝⼤⼩的窗⼝，滚动窗⼝具有固定⼤⼩，且不重叠。例如，指定⼀个⼤⼩为 5 分钟的滚动窗⼝，Flink 将每隔 5 分钟 ...

By数据与后端架构提升之路2023年11月06日

源码概览 jobmanager scheduler：这部分与 Flink 的任务调度有关。 CoLocationConstraint：这是一个约束类，用于确保某些算子的不同子任务在同一个 TaskMa ...