Hello team, I have Flink Job that is using Table API, Input log in the Flink Job has a diff log schema, let’s say log1 has {x=1,y=“abc”,z=true} log2 has {x=1,a=“yu”,b=false} in future I can have other fields As far as I have explored Table API I need fix schema, But in this example I can not make schema correct, So how can I make dynamic schema on the each rule? Thank you so much, I highly appreciate your reply

Think about the Table API like you’d think about a relational database like MySQL: can you

make dynamic schema on the each rule?

Not really. If you use specific types you either need to come up with a wrapper (like I mentioned here) or lose some of the types (e.g. encode things as a String).

What do you mean by Wrapper? Can you give an example?

See the link I shared. Just a wrapper type / row that contains fields with the values you need.

Okay, Let me go through it