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 kcz <57...@qq.com> on 2020/10/22 01:38:01 UTC

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

这里我当时也想要弄一下,不过失败了我。最后用了calcite来弄,你这块具体是如何去弄的?





------------------ 原始邮件 ------------------
发件人: 马阳阳 <ma_yang_yang@163.com&gt;
发送时间: 2020年10月19日 17:58
收件人: Flink中文邮件列表 <user-zh@flink.apache.org&gt;
主题: 回复: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。


谢谢~