Re: Avro schema

2021-04-02 Thread Paul Lam
Hi Sumeet, I’m not a Table/SQL API expert, but from my knowledge, it’s not viable to derived SQL table schemas from Avro schemas, because table schemas would be the ground truth by design. Moreover, one Avro type can be mapped to multiple Flink types, so in practice maybe it’s also not viable.

Union of more then two streams

2021-04-02 Thread B.B.
Hi, I have an architecture question regarding the union of more than two streams in Apache Flink. We are having three and sometime more streams that are some kind of code book with whom we have to enrich main stream. Code book streams are compacted Kafka topics. Code books are something that does