Question about Flink SQL - I’m trying to generate a very big query that queries from 100 kafka topics (sink to a single kafka topic). What is better? 1. UNION ALL (each one of the 100 queries altogether) 2. multiple (100) INSERT queries - all to a single kafka topic So far I tried only (1), but the query is way too big (due to schema diffs, there’s a very big

CAST(X as …) AS …

for each query. Any other suggestions are welcome 🙂