[
https://issues.apache.org/jira/browse/FLINK-16630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060745#comment-17060745
]
jackray wang commented on FLINK-16630:
--------------------------------------
[~twalthr] You can define a json string like \{"@version":"1.2.3"} send to
kafka, and define a source table to parse the data from kafka.
{code:java}
// how to reproduce the issue
create table souce_table(
'@version' STRING
)with(………………)
{code}
When you run the script in FLINK SQL Client will see the errors
> '@version' STRING is not support
> ---------------------------------
>
> Key: FLINK-16630
> URL: https://issues.apache.org/jira/browse/FLINK-16630
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
> Affects Versions: 1.10.0
> Reporter: jackray wang
> Priority: Major
>
> {code:java}
> // After the data is processed by logstash, the following fields will appear
> create table ss(
> '@version' STRING
> )
> {code}
> {code:java}
> [ERROR] Could not execute SQL statement. Reason:
> org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered
> "\'@version\'" at line 2, column 1. Was expecting one of: "PRIMARY" ...
> "UNIQUE" ... "WATERMARK" ... <BRACKET_QUOTED_IDENTIFIER> ...
> <QUOTED_IDENTIFIER> ... <BACK_QUOTED_IDENTIFIER> ...
> {code}
>
> what is the @ ‘s means in flinksql？ can you support this feature？
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
