Questions about java enum when convert DataStream to Table

2023-08-01 Thread haishui
I want to convert dataStream to Table. The type of dataSream is a POJO, which contains a enum field. 1. The enum field is RAW('classname', '...') in table. When I execute `SELECT * FROM t_test` and print the result, It throws EOFException. 2. If I assign the field is STRING in schema, It throws

Re:Kafka source with idleness and alignment stops consuming

2023-06-27 Thread haishui
Hi, I have the same trouble. This is really a bug. `shouldWaitForAlignment` needs to be another change. By the way, a source will be marked as idle, when the source has waiting for alignment for a long time. Is this a bug? 在 2023-06-27 23:25:38,"Alexis Sarda-Espinosa" 写道: He