FLINK SQL 1.10 如何直接将bigint类型时间数据转换为Timestamp类型数据而不把BIGINT类型数据转换为字符串类型时间数据再处理。

Question

我是Flink新手，正在学习flink sql相关开发，参考的阿里云开发文档进行学习
https://www.alibabacloud.com/help/zh/faq-detail/64813.htm?spm=a2c63.q38357.a3.3.368d1352JdVsRU

我现在有一些13位的bigint格式时间数据，想把他们转换成timestamp格式数据。开发手册上说可以直接用TO_TIMESTAMP（）函数直接处理，但我使用时会报错说

Caused by: org.apache.calcite.sql.validate.SqlValidatorException: Cannot apply 'TO_TIMESTAMP' to arguments of type 'TO_TIMESTAMP(<BIGINT>)'. Supported form(s): 'TO_TIMESTAMP(<CHARACTER>)'
'TO_TIMESTAMP(<CHARACTER>, <CHARACTER>)'
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423)

我使用的是最简单的格式，其中CREATETIME为长度13位的BIGINT类型数据

SELECT TO_TIMESTAMP(CREATETIME), SUBMITTER AS username FROM kafka_databus

Answer 1

https://blog.csdn.net/zhangdongan1991/article/details/105796613