We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2a44f3f commit 9ae1097Copy full SHA for 9ae1097
1 file changed
kudu/kudu-side/kudu-async-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAsyncReqRow.java
@@ -302,7 +302,7 @@ public GetListRowCB() {
302
@Override
303
public Deferred<List<Row>> call(RowResultIterator results) throws Exception {
304
if (results == null) {
305
- resultFuture.complete(Collections.emptyList());
+ dealMissKey(input, resultFuture);
306
return null;
307
}
308
0 commit comments