请教一个问题：
需求是实现一个定时产生数据的source，按照demo中的Thread.sleep()方法控制产生数据的频率 实际运行过程中发现，checkpoint触发后会一直阻塞等待source完成，如果去掉代码中的Thread.sleep() checkpoint的过程会很快
请问如何正确实现fixed delay source的逻辑呢？
请教一个问题：需求是实现一个定时产生数据的source，按照demo中的Thread.sleep[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！