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

Jark Wu commented on FLINK-22968:
---------------------------------

But I have to admit we should improve the exception message a bit. Will change 
the title and description. 

>  String type cannot be used when creating Flink SQL
> ---------------------------------------------------
>
>                 Key: FLINK-22968
>                 URL: https://issues.apache.org/jira/browse/FLINK-22968
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / API
>    Affects Versions: 1.12.3, 1.13.1
>         Environment: {color:#FF0000}*Flink-1.13.1 and Flink-1.12.1*{color}
>            Reporter: DaChun
>            Priority: Blocker
>         Attachments: test.scala, this_error.txt
>
>
> When I run the program, the error is as follows:
> The specific error is in this_ error.txt,
> But the error prompts me to write an issue
> Caused by: org.apache.flink.api.common.InvalidProgramException: Table program 
> cannot be compiled. This is a bug. Please file an issue.
> It's very easy to read a stream and convert it into a table mode. The generic 
> type is string
> Then an error is reported. The code is in test. Scala and the error is in 
> this_ error.txt
> But I try to create an entity class by myself, and then assign generics to 
> this entity class, and then I can pass it normally,
> Or with row type, do you have to create your own entity class, not with 
> string type?
>  
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to