flink 读parquet乱码
时间: 2023-09-09 13:07:00 浏览: 163
如果使用Flink读取Parquet文件时遇到乱码问题,可以尝试以下解决方法:
1. 确认输入文件编码格式是否正确,可以使用其他工具先检查一下文件内容是否正常。
2. 确认Flink环境的编码设置是否正确,可以在启动Flink Job时添加参数 -Dfile.encoding=utf-8 来设置编码格式。
3. 确认Flink和Parquet版本是否兼容,可以尝试升级Flink或Parquet的版本来解决问题。
4. 尝试使用其他方式读取Parquet文件,例如使用Hadoop的ParquetInputFormat来读取文件,看是否能解决乱码问题。
如果以上方法都无法解决问题,可以考虑联系Flink社区或Parquet开发者寻求帮助。
阅读全文