Hello,
I have started doing https://issues.apache.org/jira/browse/FLINK-4743 What should explain of DataStream look like? Best regards, Anton |
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:[hidden email]] Sent: Wednesday, October 26, 2016 12:30 PM To: [hidden email] 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 |
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 than the batch execution plan, but I think that is fine. Please let me know if you have more questions. Best, Fabian 2016-10-26 10:59 GMT+02:00 Anton Solovev <[hidden email]>: > 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:[hidden email]] > Sent: Wednesday, October 26, 2016 12:30 PM > To: [hidden email] > 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 > |
How can I execute several tests of table explain separately?
While StreamExecutionEnvironment is up, an idCounter in StreamTransformation keeps incrementing and so each test depends on previous ones. -----Original Message----- From: Fabian Hueske [mailto:[hidden email]] Sent: Thursday, October 27, 2016 12:17 AM To: [hidden email] 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() method. The stream execution plan will probably contain different information than the batch execution plan, but I think that is fine. Please let me know if you have more questions. Best, Fabian 2016-10-26 10:59 GMT+02:00 Anton Solovev <[hidden email]>: > 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:[hidden email]] > Sent: Wednesday, October 26, 2016 12:30 PM > To: [hidden email] > 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 > |
Hi Anton,
I think we can ignore the id, do not print operator’s id in the table explain. IMO, the id information is not necessary. - Jark Wu > 在 2016年10月27日,下午8:16,Anton Solovev <[hidden email]> 写道: > > How can I execute several tests of table explain separately? > While StreamExecutionEnvironment is up, an idCounter in StreamTransformation keeps incrementing > and so each test depends on previous ones. > > > -----Original Message----- > From: Fabian Hueske [mailto:[hidden email]] > Sent: Thursday, October 27, 2016 12:17 AM > To: [hidden email] > 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() method. > The stream execution plan will probably contain different information than the batch execution plan, but I think that is fine. > > Please let me know if you have more questions. > > Best, Fabian > > 2016-10-26 10:59 GMT+02:00 Anton Solovev <[hidden email]>: > >> 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:[hidden email]] >> Sent: Wednesday, October 26, 2016 12:30 PM >> To: [hidden email] >> 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 >> |
Free forum by Nabble | Edit this page |