DTStack / flinkStreamSQL

基于开源的flink,对其实时sql进行扩展;主要实现了流与维表的join,支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 923 forks source link

Yarn模式下的sql是在什么地方解析的 #433

Closed Hoo199212 closed 2 years ago

Hoo199212 commented 2 years ago

阅读源码,发现在Yarn模式下,直接就从上下文中获取到优化计划了,没有看到sql解析的地方,所以对sql在什么时候解析的存在疑惑