From b0e70bd02bc8e50d421c62f406eb39d3e7a5c6b1 Mon Sep 17 00:00:00 2001
From: Mryange <59914473+Mryange@users.noreply.github.com>
Date: Thu, 19 Oct 2023 19:27:31 +0800
Subject: [PATCH] [fix](pipelineX) fix error set delta_urls (#25631)

---
 be/src/runtime/fragment_mgr.cpp | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 71297e0d4c..0ebb63b180 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -266,12 +266,14 @@ void FragmentMgr::coordinator_callback(const ReportStatusRequest& req) {
                 params.delta_urls.push_back(to_http_path(it));
             }
         } else if (!req.runtime_states.empty()) {
-            params.__isset.delta_urls = true;
             for (auto* rs : req.runtime_states) {
                 for (auto& it : rs->output_files()) {
                     params.delta_urls.push_back(to_http_path(it));
                 }
             }
+            if (!params.delta_urls.empty()) {
+                params.__isset.delta_urls = true;
+            }
         }
         if (req.runtime_state->num_rows_load_total() > 0 ||
             req.runtime_state->num_rows_load_filtered() > 0) {