Re: DataStream#explain

2016-10-27 Thread Jark Wu
onment is up, an idCounter in StreamTransformation > keeps incrementing > and so each test depends on previous ones. > > > -Original Message- > From: Fabian Hueske [mailto:fhue...@gmail.com] > Sent: Thursday, October 27, 2016 12:17 AM > To: dev@flink.apache.o

RE: DataStream#explain

2016-10-27 Thread Anton Solovev
, October 27, 2016 12:17 AM To: dev@flink.apache.org Subject: Re: DataStream#explain Hi Anton, I think you can do it similar as the BatchTableEnvironment#explain(table: Table, extended: Boolean) which calls ExecutionEnvironment.getExecutionPlan(). StreamExecutionPlan does also have a getExecutionPlan

Re: DataStream#explain

2016-10-26 Thread Fabian Hueske
Hi Anton, I think you can do it similar as the BatchTableEnvironment#explain(table: Table, extended: Boolean) which calls ExecutionEnvironment.getExecutionPlan(). StreamExecutionPlan does also have a getExecutionPlan() method. The stream execution plan will probably contain different information t

RE: DataStream#explain

2016-10-26 Thread Anton Solovev
Sorry, wrong issue number Question is about https://issues.apache.org/jira/browse/FLINK-4623 And in subject should be StreamExecutionEnvironment#explain actually -Original Message- From: Anton Solovev [mailto:anton_solo...@epam.com] Sent: Wednesday, October 26, 2016 12:30 PM To: dev@fli