开发者社区> 问答> 正文

FLINK SQL 1.10 如何直接将bigint类型时间数据转换为Timestamp类型数据而不

我是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

遇到了同样的问题,在CSDN看到了,希望阿里云团队能够给出正确、标准的答案~请查看

展开
收起
刘刚_ 2020-05-20 17:56:43 1940 0
1 条回答
写回答
取消 提交回答
  • 你好,已将问题转给阿里云goc团队,敬请期待

    2020-05-20 19:20:03
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载