Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.3.0
-
None
Description
Creating a table from a DataStream of POJOs fails when the user tries to define a rowtime attribute.
There are multiple reasons in ExpressionParser as well as StreamTableEnvironment#validateAndExtractTimeAttributes.
See also: https://stackoverflow.com/questions/44448022/apache-flink-1-3-table-api-rowtime-strange-behavior
Attachments
Issue Links
- links to