Flink SQL 读取时间戳字段为空问题解决:bigint 类型解析
如果在 Flink SQL 中,一个时间戳字段被错误地读取为 bigint 类型,并且在写入下游 Hive 时为空,可能是因为解析时间戳的方式不正确。
在 Flink SQL 中,可以使用 FROM_UNIXTIME 函数将 bigint 类型的时间戳转换为具体的日期时间格式。例如:
SELECT FROM_UNIXTIME(timestamp_column) AS timestamp FROM table;
确保在读取数据时,将 bigint 类型的时间戳正确解析为日期时间格式,然后再写入 Hive 表。
原文地址: https://www.cveoy.top/t/topic/lKQ1 著作权归作者所有。请勿转载和采集!