fix remote async execute -4006

5f0ce95c · ym0 · wangzelin.wzl · a24b0eb4 · 5f0ce95c
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

src/sql/executor/ob_execute_result.cpp src/sql/executor/ob_execute_result.cpp +3 -1

未找到文件。
--- a/src/sql/executor/ob_execute_result.cpp
+++ b/src/sql/executor/ob_execute_result.cpp
@@ -227,7 +227,9 @@ int ObAsyncExecuteResult::get_next_row(ObExecContext& ctx, const ObNewRow*& row)
 {
  UNUSED(ctx);
  int ret = OB_SUCCESS;
-  if (OB_ISNULL(cur_row_)) {
+  if (field_count_ <= 0) {
+    ret = OB_ITER_END;
+  } else if (OB_ISNULL(cur_row_)) {
    ret = OB_NOT_INIT;
    LOG_WARN("scanner is invalid", K(ret));
  } else if (nullptr == spec_) {