You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "huangjiatian (JIRA)" <ji...@apache.org> on 2018/09/29 10:59:00 UTC

[jira] [Created] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

huangjiatian created FLINK-10464:
------------------------------------

             Summary: TimeIndicatorRelDataType: digest can not describe a type completely.
                 Key: FLINK-10464
                 URL: https://issues.apache.org/jira/browse/FLINK-10464
             Project: Flink
          Issue Type: Bug
            Reporter: huangjiatian


I met a strange question when i use Flink SQL API.

The error message like that: 

java.lang.AssertionError: Conversion to relational algebra failed to preserve datatypes:

validated type:

RecordType(TIMESTAMP(3) NOT NULL rowtime) NOT NULL

converted type:

RecordType(TIMESTAMP(3) NOT NULL rowtime) NOT NULL

rel:

LogicalProject(rowtime=[$3])

  LogicalTableScan(table=[[hjtsrc]])

    ....

I found two difference type are considered equal.
!image-2018-09-28-13-11-43-515.png!

that mean, "select deviceid, rowtime.rowtime" equal to "select deviceid, rowtime.proctime"

"digest" in TimeIndicatorRelDataType without event time message , it can not describe a TimeIndicatorRelDataType completely.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)