[FLINK-8366] Use Row instead of String as key when process upsert results

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Component/s: Table SQL / API
• Assignee: Hequn Cheng
• Reporter: Hequn Cheng
• Created: 05/Jan/18 08:49
• Updated: 17/Apr/18 19:58
• Resolved: 17/Apr/18 19:58

Description

In TableSinkITCase.upsertResults() function, we use String as key to upsert results. This will make (1,11) and (11,1) have the same key (i.e., 111).
This bugfix use Row instead of String to avoid the String problem.

Issue Links

• links to: GitHub Pull Request #5244