You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yunfeng Zhou (Jira)" <ji...@apache.org> on 2022/06/28 08:19:00 UTC

[jira] [Created] (FLINK-28275) Table.execute().print() prints SqlRawValue

|  ![](cid:jira-generated-image-avatar-be650718-fe13-4ad5-9005-1591b22f7b8b) |
[Yunfeng
Zhou](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=yunfengzhou)
**created** an issue  
---|---  
|  
---  
|  [Flink](https://issues.apache.org/jira/browse/FLINK) / [![Bug](cid:jira-
generated-image-
avatar-2eb59526-f34b-4dbe-b3d1-49e4010d753b)](https://issues.apache.org/jira/browse/FLINK-28275)
[FLINK-28275](https://issues.apache.org/jira/browse/FLINK-28275)  
---  
[Table.execute().print() prints
SqlRawValue](https://issues.apache.org/jira/browse/FLINK-28275)  
| Issue Type: |  ![Bug](cid:jira-generated-image-
avatar-2eb59526-f34b-4dbe-b3d1-49e4010d753b) Bug  
---|---  
Affects Versions: |  1.15.0  
Assignee: |  Unassigned  
Components: |  Table SQL / API  
Created: |  28/Jun/22 08:18  
Environment: |

Flink 1.15

Flink ML 2.1  
  
Priority: |  ![Major](cid:jira-generated-image-static-
major-a6cd8ceb-08d3-4cfe-b3e1-fbdc3edab23f) Major  
Reporter: |  [Yunfeng
Zhou](https://issues.apache.org/jira/secure/ViewProfile.jspa?name=yunfengzhou)  
|

If the following code is executed with Flink 1.15.0 and Flink ML 2.1



    
    
    import org.apache.flink.ml.linalg.Vectors;
    import org.apache.flink.streaming.api.datastream.DataStream;
    import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
    import org.apache.flink.table.api.Table;
    import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
    import org.apache.flink.types.Row;
    
    public class SqlRawValueExample {
    public static void main(String[] args) {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
    
    DataStream<Row> dataStream = env.fromElements(Row.of(Vectors.dense(1.0, 2.0)));
    Table table = tEnv.fromDataStream(dataStream);
    
    table.execute().print();
    }
    }



The following result would be printed out



    
    
    +----+--------------------------------+
    | op |                             f0 |
    +----+--------------------------------+
    | +I |                 SqlRawValue{?} |
    +----+--------------------------------+



while the expected result is

    
    
    +----+--------------------------------+
    | op |                             f0 |
    +----+--------------------------------+
    | +I |                     [1.0, 2.0] |
    +----+--------------------------------+

This behavior affects the readability of the generated results.

  
  
---  
|  |  [ ![Add Comment](cid:jira-generated-image-static-comment-
icon-c3807ced-7df5-4ffb-a9ae-f7230d94082c)
](https://issues.apache.org/jira/browse/FLINK-28275#add-comment "Add Comment")
|  [Add Comment](https://issues.apache.org/jira/browse/FLINK-28275#add-comment
"Add Comment")  
---|---  
  
|  This message was sent by Atlassian Jira (v8.20.10#820010-sha1:ace47f9) |  |
![Atlassian logo](https://issues.apache.org/jira/images/mail/atlassian-email-
logo.png)  
---