这个Flink问题怎么解决?[阿里云实时计算 Flink版]

这个Flink问题怎么解决?有一个无限的DataStream数据流,我想执行
tEnv.createTemporaryView(“source”, stream);
tEnv.executeSql(“INSERT INTO sink select * from source”); 该怎么设置sql的触发事件啊,因为发现这样写不进去,但如果是有限的数据就能写进去,我尝试用了运动时间窗口,想让他在窗口时间内执行发现还是不能写进去。

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====