fix not return error code

2023-06-26 02:42:32 +00:00
parent c79361d9d7
commit c6229c04a6
1 changed files with 1 additions and 1 deletions
--- a/src/sql/engine/px/ob_granule_pump.cpp
+++ b/src/sql/engine/px/ob_granule_pump.cpp
@ -1578,7 +1578,7 @@ int ObGranulePump::regenerate_gi_task()
  no_more_task_from_shared_pool_ = false;
  for (int i = 0; i < pump_args_.count() && OB_SUCC(ret); ++i) {
    ObGranulePumpArgs &arg = pump_args_.at(i);
-    if (add_new_gi_task(arg)) {
+    if (OB_FAIL(add_new_gi_task(arg))) {
      LOG_WARN("failed to add new gi task", K(ret));
    }
  }