你这没有把dialect set成hive吧，走到了else分支。default dialect是需要指定connector的，参考文档的kafka到hive代码 https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/hive/hive_read_write.html#writing
-- Sent from: http://apache-flink.147419.n8.nabble.com/
