Flink

在大数据处理上，Hadoop并非是唯一的分布式处理架构，但是对于大部分的企业来说，基于Hadoop已经能够满足绝大部分的数据需求，因此才会成为现在的主流选择。 今天 ，终终终于卷完…

本文首发于我的个人博客网站 等待下一个秋-Flink 什么是CDC？ CDC是（Change Data Capture 变更数据获取）的简称。核心思想是，监测并捕获数据库的变动（包…

1.官方下载地址  https://flink.apache.org/zh/downloads.html#apache-flink-1144    最好用国内镜像下载比较快   下…

Calcite 是什么？如果用一句话形容 Calcite，Calcite 是一个用于优化异构数据源的查询处理的基础框架。 最近十几年来，出现了很多专门的数据处理引擎。例如列式存储 …

一、一致性检查点（Checkpoints） Flink故障恢复机制的核心，就是应用状态的一致性检查点有状态流应用的一致性检查点，其实就是所有任务的状态，在某个时间点的一份拷贝（一份…

一、错误日志 2022-08-30 03:14:45 org.apache.flink.streaming.runtime.tasks.AsynchronousException:…

@ 目录 概述 定义 使用场景 特点 工作流程 连接器 转换 为何选择SeaTunnel 安装 下载 配置文件 部署模式 入门示例 启动脚本 配置文件使用参数示例 Kafka进Ka…

一、错误日志 org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Error…

按照以下代码测试定义的UDAGG会一直出现org.apache.flink.table.api.ValidationException: SQL validation failed…

1.Flink-sql自定义UDAF函数 – 简书 (jianshu.com) 2.Flink SQL 自定义UDAF_k_wzzc的博客-CSDN博客_flink u…