2026年4月8日

flinksql 同步数据到 hudi

摘要： -- 1. 基础环境配置SET 'execution.runtime-mode' = 'streaming'; -- 建议设为流模式，实时触发更新SET 'execution.checkpointing.interval' = '30s'; -- Hudi 必须开启 Checkpoint 才能提交数 阅读全文

posted @ 2026-04-08 09:11 飞行的蟒蛇 阅读(3) 评论(0) 推荐(0)

flinkcdc断点续传

摘要： package com.atguigu.flink; import com.ververica.cdc.connectors.mysql.source.MySqlSource; import com.ververica.cdc.connectors.mysql.table.StartupOption 阅读全文

posted @ 2026-04-08 09:01 飞行的蟒蛇 阅读(5) 评论(0) 推荐(0)