Hi seatunnel community, According to issue #2371 and #2299, supporting user-defined schema in source connectors is a import feature for seatuunel.
In this email I want to discuss with you how to implement it. In my option, I think we can add a new config option named as *schema* in all source connector source configs and for each connector they can parse their own schema in *getProducedType* method. The implement function of parsing schema we can add it in module *seatunnel-common*. And I agree with your advice @ashulin to conform schema type to the habit of SQL the same as defined in code as the following image show: [image: image.png] What do you think about this?Waiting for your reply! TyrantLucifer
