Merge branch '1.10_release_4.0.x' into 1.10_release_4.1.x

gituser · gituser · commit 41c3c20f5813 · 2021-05-20T18:14:52.000+08:00
diff --git a/kudu/kudu-side/kudu-async-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAsyncReqRow.java b/kudu/kudu-side/kudu-async-side/src/main/java/com/dtstack/flink/sql/side/kudu/KuduAsyncReqRow.java
@@ -302,7 +302,7 @@ public GetListRowCB() {
         @Override
         public Deferred<List<Row>> call(RowResultIterator results) throws Exception {
             if (results == null) {
-                resultFuture.complete(Collections.emptyList());
+                dealMissKey(input, resultFuture);
                 return null;
             }
 

Original file line number	Diff line number	Diff line change
`@@ -302,7 +302,7 @@ public GetListRowCB() {`
`302`	`302`	`@Override`
`303`	`303`	`public Deferred<List<Row>> call(RowResultIterator results) throws Exception {`
`304`	`304`	`if (results == null) {`
`305`		`- resultFuture.complete(Collections.emptyList());`
	`305`	`+ dealMissKey(input, resultFuture);`
`306`	`306`	`return null;`
`307`	`307`	`}`
`308`	`308`