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
bject 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@flink.apache.org > Subject: DataStream#explain > > Hello, > > > > I have

RE: DataStream#explain

2016-10-26 Thread Anton Solovev
@flink.apache.org Subject: DataStream#explain Hello, I have started doing https://issues.apache.org/jira/browse/FLINK-4743 What should explain of DataStream look like? Best regards, Anton

DataStream#explain

2016-10-26 Thread Anton Solovev
Hello, I have started doing https://issues.apache.org/jira/browse/FLINK-4743 What should explain of DataStream look like? Best regards, Anton