包含标签:flink 的文章
-
【Flink-CDC】Flink CDC 介绍和原理概述
【Flink-CDC】Flink CDC 介绍和原理概述 1)基于查询的 CDC 和基于日志的 CDC 2)Flink CDC 3)Flink CDC原理简述 4)基于 Flink SQL CDC 的数据同步方案实…… -
Flink自定义Source模拟数据流
maven依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org…… -
-
flink1.12.4消费kafka 报错 The coordinator is not available
报错 You should retry committing the latest consumed offsets. Caused by: org.apache.kafka.common.errors.CoordinatorNotAvailableException: The coor…… -
【Flink】Flink核心概念简述
目录 一、Flink 简介 二、Flink 组件栈 1. API & Libraries 层 2. runtime层 3. 物理部署层 三、Flink 集群架构 四、Flink基本编程模型 五、Flink …… -
Flink-执行拓扑图与作业调度
算子与作业提交 一、Flink执行模式 1.流执行模式 2.批执行模式 二、Flink拓扑图 1.基本概念 2.拓扑图生成过程 三、拓扑生成和优化 1.应用程序 2.…… -
Apache Doris 整合 FLINK 、 Hudi 构建湖仓一体的联邦查询入门
1.概览 多源数据目录(Multi-Catalog)功能,旨在能够更方便对接外部数据目录,以增强Doris的数据湖分析和联邦数据查询能力。 在之前的 Doris 版本中,用户数…… -
flink源码分析之功能组件(三)-rpc组件
简介 本系列是flink源码分析的第二个系列,上一个《flink源码分析之集群与资源》分析集群与资源,本系列分析功能组件,kubeclient,rpc,心跳,高可用,…… -
数据湖架构Hudi(五)Hudi集成Flink案例详解
五、Hudi集成Flink案例详解 5.1 hudi集成flink flink的下载地址: https://archive.apache.org/dist/flink/ Hudi Supported Flink version 0.12.x …… -
Flink读写Doris操作介绍
Flink读写Doris操作介绍 Flink Doris Connector 可以支持通过 Flink 操作(读取、插入、修改、删除) Doris 中存储的数据。可以将 Doris 表映射为 Data……