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)
---