I think it is currently not possible to get the AST as JSON. There is a
similar feature request here:
https://issues.apache.org/jira/browse/FLINK-19687
Best,
Dawid
On 17/11/2020 20:59, Rex Fenley wrote:
> So I tried|userDocsTable.explain()| however it doesn't give me the AST
> as JSON so that I
So I tried userDocsTable.explain() however it doesn't give me the AST as
JSON so that I can use the visualizer tool
https://ci.apache.org/projects/flink/flink-docs-stable/dev/execution_plans.html
. Also, if I get rid of executeInsert or move it to after getExecutionPlan
I still end up with "Caused
I don't think I can share the full program.
However, the program is a long series of joines and aggs against various
sources and that is the only sink.
Thanks!
On Tue, Nov 17, 2020 at 12:17 AM Khachatryan Roman <
khachatryan.ro...@gmail.com> wrote:
> Hello,
>
> Can you share the full program?
>
Hi Rex,
The executeInsert method as the name states executes the query.
Therefore after the method there is nothing in the topology and thus you
get the exception.
You can either explain the userDocsTable:
|userDocsTable.explain()|
or you can explain a statement set if you want to postpone the
Hello,
Can you share the full program?
getExecutionPlan call is probably misplaced.
Regards,
Roman
On Tue, Nov 17, 2020 at 8:26 AM Rex Fenley wrote:
> Hello,
>
> I have the following code attempting to print the execution plan for my
> job locally. The job runs fine and Flink UI displays so I
Hello,
I have the following code attempting to print the execution plan for my job
locally. The job runs fine and Flink UI displays so I'd expect this to work.
val tableResult = userDocsTable.executeInsert(SINK_ES_PEOPLE)
println(s"execution plan:\n${this.env.getExecutionPlan()}")
but instead I
