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
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