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" <[email protected]>; ????????: 2020??10??20??(??????) ????11:58 ??????: "??????"<[email protected]>; ????: "user"<[email protected]>;"dwysakowicz"<[email protected]>;"twalthr"<[email protected]>; ????: Re: 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 ?????? <[email protected]> wrote: I'm learning "select"from official document my code is: https://paste.ubuntu.com/p/yVYhZqMNq7/ the error I got is: total 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
