问flink 多source多sink情况怎么循环同时执行？

提问于 2024-01-11 15:55:14

回答 1关注 0查看 206

一个主题对应一张表，现在表个数不固定，想通传参的方式传入程序。目前是初始化env后循环初始化source然后处理完再sink，最后execute。问题是循环中只有第一个主题的数据能读出来然后写出去，后面的都写不进去怎么解决。