Re:Re: How does Flink SQL read Avro union?

2021-03-31 Thread Vincent Dong
ma, maybe try it out: record RowEvent { union { null, ItemRow } item_row default null; union { null, RefundRow } refund_row default null; } On Thu, Mar 18, 2021 at 7:35 AM Vincent Dong wrote: Hi All, How does Flink SQL read Kafka Avro message which has union field? For

How does Flink SQL read Avro union?

2021-03-17 Thread Vincent Dong
nverts all messages to RefundRow? Then I can `select status, refund_id from the_converted_table`. Thanks Vincent Dong