????FlinkSQL????????????1??????????Flink1.90??????sql??????Kafka??????????????????????????Kafka??????????????csv????????kafka??format???????????????
??????????







Caused by: org.apache.flink.table.api.ValidationException: Could not map the 
schema field 'fruit' to a field from source. Please specify the source field 
from which it can be derived.


????format????????????????? ??????

回复