Hi All, We have a use case for

JDBC sink

wherein we are trying to exclude some fields if their value is null in the final upsert/insert query which is provided to sink function. The preparedStatement that currently accepts a pre prepared query only which is provided via jdbc statement builder. Wanted to know if there is any alternate way we can provide queries to the jdbc sink on the basis of incoming record from stream so we can prepare our own query in runtime instead of using a prepared template query for insert/upsert. Flink version : 1.14 Thanks for the help !