You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/10/01 07:46:00 UTC
[jira] [Commented] (FLINK-10464) TimeIndicatorRelDataType: digest
can not describe a type completely.
[ 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)