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 <https://www.remind.com/> | BLOG <http://blog.remind.com/>
| FOLLOW
US <https://twitter.com/remindhq> | LIKE US
<https://www.facebook.com/remindhq>
