flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Simone Robutti (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment
Date Fri, 09 Sep 2016 08:21:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15476310#comment-15476310

Simone Robutti commented on FLINK-4599:

I began working on this. It seems to work by simply adapting the code used for the Batch Table.
I also replicated the tests, removing the join tests. They work but the output is different.
The main difference is due to the Plan nodes missing the globalProperties field. There's an
unsafe access and I fixed that but I'm not sure if these informations are meaningful for the
"explain test" or if it's ok if those are null. In that case, I will create dedicated .out
files for the stream explain tests.

> Add 'explain()' also to StreamTableEnvironment
> ----------------------------------------------
>                 Key: FLINK-4599
>                 URL: https://issues.apache.org/jira/browse/FLINK-4599
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>            Reporter: Timo Walther
>            Assignee: Simone Robutti
>              Labels: starter
> Currenlty, only the BatchTableEnvironment supports the {{explain}} command for tables.
We should also support it for the StreamTableEnvironment.

This message was sent by Atlassian JIRA

View raw message