flink动态更新信息
flink吧
全部回复
仅看楼主
level 1
植好F
楼主
请问一下，我读取玩kafka数据，将其转换为table，从文件读取要执行的sql，然后对table进行sql运行，我想没隔一段时间就重新获取要执行的sql，而不是重启flink，这样可行么？如果可行，能告诉怎么实现么
2019年01月29日 03点01分
1
level 1
huberyyuan
不同的sql对应着不同的source table的schema的，你的sql为什么变啊？如果变得与你的table schema不符合肯定是没法执行的。
不同的sql不可以当作不同的flink作业来执行吗？
2019年03月08日 04点03分
2
level 1
venb296997414
请问楼主，这个问题解决了么？我也遇到了类似的问题。
2019年12月10日 07点12分
3
1
![[呵呵]](/static/emoticons/u5475u5475.png)