You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 刘首维 <li...@autohome.com.cn> on 2020/10/20 02:22:10 UTC

答复: Flink 1.11里如何parse出未解析的执行计划

Hi,



 我之前跟你有相同的需求，实现方式也跟你的思路基本类似， mock一个env 然后反射获取calciteParserSupplier


目前在生产环境运行良好

FYI

________________________________
发件人: 马阳阳 <ma...@163.com>
发送时间: 2020年10月19日 17:57:47
收件人: Flink中文邮件列表
主题: Flink 1.11里如何parse出未解析的执行计划

Flink 1.11里的org.apache.flink.table.planner.ParserImpl的parse方法里包含了对Planner相关方法的调用，这导致在某些前置sql（例如insert into用到的表的create table语句）没有执行之前，这个parse方法会报错。如果只是想调用Calcite的相关的功能去parse sql语句，有什么办法可以做到吗？能想到的一个办法是通过反射拿到ParserImpl里面的calciteParserSupplier。想知道Flink有没有提供直接的接口或者方法去做纯的sql parsing。


谢谢~