Create a function that verifies whether a table's schema includes `key` and `val` with both fields are defined as `BYTES` data type. If the table has this schema definition, then apply the schema supplied to the function.

[j3-signalroom]

I discovered that when a Kafka topic is created via Terraform without a defined schema attached, Flink will automatically associate one by default. This is particularly troublesome when the table is linked to a sink topic. When inserting records into that topic, I encountered a mismatch error between the query schema and the sink schema, which resulted in the Flink Job failing.

[j3-signalroom]

During my preliminary research, I could not find in the Confluent Cloud for Apache Flink (CCAF) Table API method that does the action of the Flink SQL ALTER TABLE statement. So, I need to use the execute_sql method instead and execute a Flink SQL statement.