Re: IllegalStateException Printing Plan

Posted by Rex Fenley on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/IllegalStateException-Printing-Plan-tp39522p39553.html

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 <[hidden email]> wrote:

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 <[hidden email]> 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'd expect this to work.

val tableResult = userDocsTable.executeInsert(SINK_ES_PEOPLE)

println(s"execution plan:\n${this.env.getExecutionPlan()}")

but instead I end up with

Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.

What am I doing wrong?

--

Rex Fenley  |  Software Engineer - Mobile and Backend

Remind.com |  BLOG  |  FOLLOW US  |  LIKE US

--