Thanks for the pointer .. I will try debugging. I am getting this exception running my application on Kubernetes using the Flink operator from Lyft.
regards. On Sat, 21 Sep 2019 at 6:44 AM, Dian Fu <dian0511...@gmail.com> wrote: > This exception is used internally to get the plan of a job before > submitting it for execution. It's thrown with special purpose and will be > caught internally in [1] and will not be thrown to end users usually. > > You could check the following places to find out the cause to this problem: > 1. Check the execution environment you used > 2. If you can debug, set a breakpoint at[2] to see if the type of the env > wrapped in StreamPlanEnvironment is OptimizerPlanEnvironment. Usually it > should be. > > Regards, > Dian > > [1] > https://github.com/apache/flink/blob/e2728c0dddafcfe7fac0652084be6c7fd9714d85/flink-clients/src/main/java/org/apache/flink/client/program/OptimizerPlanEnvironment.java#L76 > [2] > https://github.com/apache/flink/blob/15a7f978a2e591451c194c41408a12e64d04e9ba/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamPlanEnvironment.java#L57 > > 在 2019年9月21日，上午4:14，Debasish Ghosh <ghosh.debas...@gmail.com> 写道： > > Hi - > > When you get an exception stack trace like this .. > > Caused by: > org.apache.flink.client.program.OptimizerPlanEnvironment$ProgramAbortException > at > org.apache.flink.streaming.api.environment.StreamPlanEnvironment.execute(StreamPlanEnvironment.java:66) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1507) > at > org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.scala:654) > > what is the recommended approach of debugging ? I mean what kind of errors > can potentially lead to such a stacktrace ? In my case it starts from > env.execute(..) but does not give any information as to what can go wrong. > > Any help will be appreciated. > > regards. > > -- > Debasish Ghosh > http://manning.com/ghosh2 > http://manning.com/ghosh > > Twttr: @debasishg > Blog: http://debasishg.blogspot.com > Code: http://github.com/debasishg > > > -- Sent from my iPhone
