[FLINK-15155] Join with a LookupableTableSource: the defined order lookup keys are inconsistent

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.1
• Fix Version/s: 1.9.1
• Component/s: API / DataStream

Environment

win10_x64

idea2019.2.4_x64

jdk1.8.0_211_x64

• Assignee: Unassigned
• Reporter: Rockey Cui
• Created: 09/Dec/19 12:33
• Updated: 12/Dec/19 03:45
• Resolved: 12/Dec/19 03:45

Description

My DQL==>

SELECT
D1.S_INT ,
D1.S_LONG ,
D1.S_NUMBER1 ,
D1.S_ADDRESS ,
D1.S_DATE_EVENT ,
D1.S_TIMESTAMP_EVENT
FROM
CIRROSTREAM_DIM_GHL_SOURCE_131111_CSL AS F1 LEFT JOIN CIRROSTREAM_DIM_GHL_DIM_131111 FOR SYSTEM_TIME AS OF F1.PROCTIME AS D1
ON F1.S_INT = D1.S_INT
AND F1.S_LONG = D1.S_LONG
AND F1.S_NUMBER1 = D1.S_NUMBER1
AND F1.S_ADDRESS = D1.S_ADDRESS
WHERE
F1.S_INT BETWEEN 1501 AND 2000

---

My LookupableTableSource.getAsyncLookupFunction received lookupKeys==>

0 = "S_ADDRESS"
1 = "S_INT"
2 = "S_LONG"
3 = "S_NUMBER1"

---