Flink集成使用(1) 查询数据 Flink SQL 读取 Hudi 表支持批与流两种模式,MOR 表流读通过读取日志尾部增量记录实现近实时消费: plaintext 批(快照)读取 SELECT FROM orders WHERE orderdate '20260917'; 流式读取(读取表增量,持续输出新写入数据) SET execution.runtimemode streaming; SELECT FROM orders /+ OPTIONS('read.streaming.enabled''true', 'read.startcommit''20260917093000123') /; 流读相关主要参数:read.streaming.enabled(是否流读)、read.startcommit(起始消费时刻)、read.streaming.checkinterval(增量检查间隔,默认 30 秒)。 Flink 集成注意事项 1、流式写入必须开启 Checkpoint,Checkpoint 间隔即为数据可见延迟; 2、MOR 表建议保持默认异步压缩(compaction.async.enabledtrue),避免日志堆积拖慢快照查询; 3、同一张表不可同时被 Spark 与 Flink 写入,跨引擎写入会因并发提交冲突失败;读写可跨引擎(Flink 写、Spark 读或反之); 4、Flink 写入无推测执行问题(推测执行为 Spark 特有),Spark 侧写入的推测执行限制见"使用说明环境准备"。
来自: