如果在Flink SQL中,一个时间戳字段被错误地读取为bigint类型,并且在写入下游Hive时为空,可能是因为解析时间戳的方式不正确。

在Flink SQL中,使用FROM_UNIXTIME函数将bigint类型的时间戳转换为具体的日期时间格式。例如:

SELECT FROM_UNIXTIME(timestamp_column) AS timestamp FROM table;

确保在读取数据时,将bigint类型的时间戳正确解析为日期时间格式,然后再写入Hive表。

flinksql读取数据时一个时间戳字段当成了bigint读进来 但是写进下游hive的时候为空

原文地址: https://www.cveoy.top/t/topic/i8ts 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录