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?
> getExecutionPlan call is probably misplaced.
>
> Regards,
> Roman
>
>
> On Tue, Nov 17, 2020 at 8:26 AM Rex Fenley <r...@remind101.com> 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 <https://www.remind.com/> | BLOG <http://blog.remind.com/>
>> | FOLLOW US <https://twitter.com/remindhq> | LIKE US
>> <https://www.facebook.com/remindhq>
>>
>
--
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>
