We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ca8d08d commit 2b0af47Copy full SHA for 2b0af47
rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncReqRow.java
@@ -88,7 +88,7 @@ protected void init(SideInfo sideInfo) {
88
89
@Override
90
public void asyncInvoke(CRow input, ResultFuture<CRow> resultFuture) throws Exception {
91
- CRow copyCrow = new CRow(input.row(), input.change());
+ CRow copyCrow = new CRow(Row.copy(input.row()), input.change());
92
JsonArray inputParams = new JsonArray();
93
for (Integer conValIndex : sideInfo.getEqualValIndex()) {
94
Object equalObj = copyCrow.row().getField(conValIndex);
0 commit comments