Skip to content

Commit c90aa53

Browse files
committed
[fix] 维表JOIN多个字段值失败
1 parent 23ffc03 commit c90aa53

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/main/java/com/dtstack/flink/sql/side/BaseAsyncReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,7 +194,7 @@ public void asyncInvoke(Row row, ResultFuture<BaseRow> resultFuture) throws Exce
194194
}
195195

196196
private Map<String, Object> parseInputParam(Row input) {
197-
Map<String, Object> inputParams = Maps.newHashMap();
197+
Map<String, Object> inputParams = Maps.newLinkedHashMap();
198198
for (int i = 0; i < sideInfo.getEqualValIndex().size(); i++) {
199199
Integer conValIndex = sideInfo.getEqualValIndex().get(i);
200200
Object equalObj = input.getField(conValIndex);

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -338,7 +338,7 @@ private void handleQuery(SQLConnection connection, Map<String, Object> inputPara
338338
}
339339

340340
private Map<String, Object> formatInputParam(Map<String, Object> inputParam) {
341-
Map<String, Object> result = Maps.newHashMap();
341+
Map<String, Object> result = Maps.newLinkedHashMap();
342342
inputParam.forEach((k, v) -> {
343343
result.put(k, convertDataType(v));
344344
});

0 commit comments

Comments
 (0)