[FLINK-15537] Type of keys should be `BinaryRow` when manipulating map state with `BaseRow` as key type.

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.1
• Fix Version/s: 1.10.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Shuo Cheng
• Reporter: Shuo Cheng
• Created: 09/Jan/20 10:25
• Updated: 19/Jan/20 06:51
• Resolved: 19/Jan/20 06:51

Description

`BaseRow` is serialized and deserialized as `BinaryRow` by default, so when the key type of the map state is `BaseRow`, we should construct map keys with `BinaryRow` as type to get value from map state, otherwise, you would  always get Null...

Try it with following SQL:

// (b: Int, c: String)
SELECT 
      b, listagg(DISTINCT c, '#')
FROM MyTable
GROUP BY b

 

Issue Links

• links to: GitHub Pull Request #10815