一、背景公司需要将Doris数据库中的部分表数据同步至SFTP服务器，以供其他合作企业安全读取和使用。目前，平台数据同步功能统一使用Flink引擎进行实时同步、离线同步的工作。因此，希望能够充分利用现有的Flink引擎，并将...

目录0. 相关文章链接1. 为什么要实现将业务数据实时写入到数据仓库中2. 架构设计3. FlinkSQL将binlog写入到HDFS中4. 创建增量外部表（binlog表）5. 主作业5.1. 概述5.2. fmys_go...

本文目录 0 简介1 编程基础2 表概念相关3 建表相关4 表定义相关4.1 schema字段定义4.2 format详解4.3 watermark与时间属性详解4.4 connector详解 5 cdc连接器6 流表...