Re: 回复： rename error in flink sql

[Timo Walther]

Hi,

sorry for the late reply. I the problem was in the 
`tEnv.toAppendStream(result,Order.class).print();` right?

You can also find a new example here:

https://github.com/apache/flink/blob/master/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/GettingStartedExample.java

We are in the process of adding more example code for beginners.

I will reply to your JIRA issue in the comments.

Regards,
Timo


On 21.10.20 07:17, ?????? wrote:
Thanks for your help,I have finally modify it and solve it by luck.

but new relevent question occur:
https://issues.apache.org/jira/browse/FLINK-19746
Could you please have a look at it?

*I know JIRA is for bug only,but the email will destroy the table I posted,*
*forgive me for posting in JIRA and close it if you think it's not a bug.*

Thanks for your help


------------------?0?2?????????0?2------------------
*??????:* "??????" <appleyu...@foxmail.com>;
*????????:*?0?22020??10??21??(??????) ????10:54
*??????:*?0?2"Andrey Zagrebin"<azagre...@apache.org>;
*????:*?0?2"user"<user@flink.apache.org>;"dwysakowicz" 
<dwysakow...@apache.org>;"twalthr"<twal...@apache.org>;
*????:*?0?2?????? rename error in flink sql


Thanks for your replies.

um....
Could you tell me *where I am wrong in this code?*
*I'm weak in Java.*
*
*
The pojo is copied from flink official example:
https://paste.ubuntu.com/p/kRKxwBpSVK/

the test code is:
https://paste.ubuntu.com/p/yVYhZqMNq7/

Thanks for your help~!


------------------ ???????? ------------------
*??????:* "Andrey Zagrebin" <azagre...@apache.org>;
*????????:*?0?22020??10??20??(??????) ????11:58
*??????:*?0?2"??????"<appleyu...@foxmail.com>;
*????:*?0?2"user"<user@flink.apache.org>;"dwysakowicz" 
<dwysakow...@apache.org>;"twalthr"<twal...@apache.org>;
*????:*?0?2Re: rename error in flink sql

Hi,

I am not an SQL expert but I would not expect the original POJO to match 
the new row with the renamed field.
Maybe Timo or Dawid have to add something.

Best,
Andrey

On Tue, Oct 20, 2020 at 4:56 PM ?????? <appleyu...@foxmail.com 
<mailto:appleyu...@foxmail.com>> wrote:


    I'm learning "select"from
    official document
    
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/tableApi.html>


    my code is:
    https://paste.ubuntu.com/p/yVYhZqMNq7/

    the error I got is:
     ?0?2total is not found in PojoType<Order, fields = [amount: Integer,
    product: String, user: Long]>

    It's strange that the*renamed field should be found in pojo.*
    *
    *
    *Could anyone help me?*
    *thanks for your help*