如何获取Flink table api/sql code gen 代码

Currently Flink DO NOT provides a direct way to get code gen code. But there are indirect ways to try. 1) debug in IDE Flink use Janino to compile all code gen code, and there is a single entry point [1] https://github.com/apache/flink/blob/master/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/generated/CompileUtils.java for Blink planner, [2] https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/Compiler.scala for old planner, you can set breakpoint there and get the code.

2) enable debug logging Blink planner logging code in CompileUtils, and old planner logging code in subclass of Compiler

3) use Janino options Janino caches code in tmp directory, and you can enable these options[3] https://github.com/janino-compiler/janino/blob/master/janino/src/main/java/org/codehaus/janino/Scanner.java#L71. Note: org.codehaus.janino.source_debugging.keep is not supported in current Janino version, which means this method can only be used to debug in IDE(need breakpoint to keep source code)

[1] https://github.com/apache/flink/blob/master/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/generated/CompileUtils.java [2] https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/Compiler.scala [3] https://github.com/janino-compiler/janino/blob/master/janino/src/main/java/org/codehaus/janino/Scanner.java#L71*来自志愿者整理的flink邮件归档