DataStream#explain

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

DataStream#explain

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
Reply | Threaded
Open this post in threaded view
|

RE: DataStream#explain

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:[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
Reply | Threaded
Open this post in threaded view
|

Re: DataStream#explain

Fabian Hueske-2
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
>
Reply | Threaded
Open this post in threaded view
|

RE: DataStream#explain

Anton Solovev
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
>
Reply | Threaded
Open this post in threaded view
|

Re: DataStream#explain

伍翀(云邪)
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
>>