多个setinterval（多个省份迎来养老金,重新核算和补差,看看你在吗?）

flink sql-client方式从kafka读取数据，然后写入iceberg。读取没问题，没有写入是怎么回事儿？感觉像是没有提交，查了下checkpoint触发次数为0，但是我是设置了checkpoint的：

Flink SQL> set execution.checkpointing.interval=10000;

太难了！

习惯了linux底层的通畅，感觉搞大数据像做黑盒测试，一个组件换一个组件的，用着是很方便，但是一出问题就有点隔靴搔痒的感觉，找不到骚点。