我是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看到了,希望阿里云团队能够给出正确、标准的答案~请查看
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。