I have Flink DataStream job that flows like this: before DataStream definition define list of Kafka Topics
I have flink 1.14.4 job that have 2 kafka sources and 2 kafka sinks. After a time my job failed on the error
I\'m trying to merge three stream into a single stream. Tried union but was unable to proceed as the schema\'s are different and if I merge the schema it becomes too large.