Hi, why can't I union two streams that both produce rows of different schemas?

Cannot union streams of different types: Row(f0: String, f1: Integer) and Row(f0: String, f1: Integer, f2: String, f3: Integer)

Is there a work around for this? I have a use case where I have one DataStream that is the "source" (Debezium change events of multiple tables), It is then split into streams with OutputTags, where each stream contains change events of a single table. Then I need to unify these streams and sink them.

you can use the connect() function that allows multiple inputs to have different schemas