[ https://issues.apache.org/jira/browse/FLINK-8400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timo Walther resolved FLINK-8400. --------------------------------- Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5: e44700061fb9bf1813f86ef223ecf285b1f9d83a > Use the lexicographic smallest attribute as the common group id when extract > unique key > --------------------------------------------------------------------------------------- > > Key: FLINK-8400 > URL: https://issues.apache.org/jira/browse/FLINK-8400 > Project: Flink > Issue Type: Bug > Components: Table API & SQL > Reporter: Hequn Cheng > Assignee: Hequn Cheng > Fix For: 1.5.0 > > > {{UniqueKeyExtractor}} will return a tuple, the first element is the name of > a key field, the second is a group name that is shared by all equivalent key > fields. The group names are used to identify same keys, for example: > select('pk as pk1, 'pk as pk2), both pk1 and pk2 belong to the same group, > i.e., pk1. Here we use the lexicographic smallest attribute as the common > group id. > Currently, when extract unique keys from DataStreamCalc, the generated group > id is not the lexicographic smallest attribute. -- This message was sent by Atlassian JIRA (v6.4.14#64029)