Flink中parquet文件的类型是在建表的时候指定的么？

不是，你要在shell-shell的那个黑框命令行里面，读取一下你的parquet文件，然后打印下他的Schema,再跟你的hive表的建表语句：show create table ***里面的字段类型逐一compare一下，然后看看他们的differentia，一般应该是parquet的schema里面有个long类型，被你hive里面该字段定义成了int，或者相反，不兼容导致的； spark.read.parquet("/tmp/output/people.parquet")..printSchema()，parquet和orc都是带schema的文件，简单理解就是自带字段和字段类型的文件，你的hive建表语句选类型的时候要与之对应，不能像csv或者txt一样那么的为所欲为，此回答整理自钉群“【③群】Apache Flink China社区”