[
https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16633676#comment-16633676
]
Timo Walther commented on FLINK-10464:
--------------------------------------
[~huangjiatian] could you add a more complete example of your table program to
reproduce your error. This issue might be a duplicate of FLINK-8897. The file
that you posted is not visible.
> 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
> Priority: Minor
>
> 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)