liqi316 created FLINK-18266:
-------------------------------

             Summary: 在表中使用proctime时,如果sql中不对强转,任务输出有问题
                 Key: FLINK-18266
                 URL: https://issues.apache.org/jira/browse/FLINK-18266
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API, Table SQL / Planner
    Affects Versions: 1.9.1
            Reporter: liqi316


当注册表的时候,指定了proctime,但是在select * from talbe 的时候会报类型无法转换。

Caused by: java.lang.ClassCastException: java.time.LocalDateTime cannot be cast 
to java.lang.LongCaused by: java.lang.ClassCastException: 
java.time.LocalDateTime cannot be cast to java.lang.Long at 
org.apache.flink.api.common.typeutils.base.LongSerializer.copy(LongSerializer.java:32)
 at 
org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(RowSerializer.java:93)
 at 
org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(RowSerializer.java:44)
 at 
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:635)
 ... 51 more

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to