flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timo Walther (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.
Date Mon, 01 Oct 2018 07:46:00 GMT

    [ 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)

Mime
View raw message