Skip to content

Commit 34cc582

Browse files
author
dapeng
committed
fix 重构之后的缓存格式问题
1 parent 1e23fe6 commit 34cc582

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,7 @@ private void invokeWithCache(Map<String, Object> inputParams, CRow input, Result
203203
return;
204204
}else if(ECacheContentType.SingleLine == val.getType()){
205205
try {
206-
Row row = fillData(input.row(), val);
206+
Row row = fillData(input.row(), val.getContent());
207207
resultFuture.complete(Collections.singleton(new CRow(row, input.change())));
208208
} catch (Exception e) {
209209
dealFillDataError(input, resultFuture, e);

0 commit comments

Comments
 (0)