Hi, I have two connectors created with SQL CLI. Source from Kafka/Debezium, and the sink S3 Hudi.
I can SELECT from the source table OK. I can issue INSERT INTO the sink OK. So I think both of them work fine. Both have same table structure, jus However when I do: INSERT INTO sink SELECT id, LAST_VALUE(`value`) GROUP BY id I see no data going to the sink. The hoodie metadata were there, but waiting for a very long time I get no data going to the sink. There were no errors on the tasks, and I could directly use INSERT INTO sink VALUES(1, 'test') and immediately get the result, but not with the INSERT SELECT command. Is there a buffer or something? Thanks! Dai
