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)
