This is an automated email from the ASF dual-hosted git repository.

dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit b095e5791c40cb03ccef6f8d73f417cf3a23fa79
Author: Lightman <[email protected]>
AuthorDate: Mon May 27 20:14:31 2024 +0800

    [BugFix] Remove the jobid check (#35438)
---
 be/src/agent/task_worker_pool.cpp | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/be/src/agent/task_worker_pool.cpp 
b/be/src/agent/task_worker_pool.cpp
index 61e9c4cab25..a05bd424600 100644
--- a/be/src/agent/task_worker_pool.cpp
+++ b/be/src/agent/task_worker_pool.cpp
@@ -197,9 +197,10 @@ void alter_tablet(StorageEngine& engine, const 
TAgentTaskRequest& agent_task_req
                     .tag("new_tablet_id", new_tablet_id)
                     .tag("mem_limit",
                          
engine.memory_limitation_bytes_per_thread_for_schema_change());
-            DCHECK(agent_task_req.alter_tablet_req_v2.__isset.job_id);
             SchemaChangeJob job(engine, agent_task_req.alter_tablet_req_v2,
-                                
std::to_string(agent_task_req.alter_tablet_req_v2.job_id));
+                                
std::to_string(agent_task_req.alter_tablet_req_v2.__isset.job_id
+                                                       ? 
agent_task_req.alter_tablet_req_v2.job_id
+                                                       : 0));
             status = 
job.process_alter_tablet(agent_task_req.alter_tablet_req_v2);
         } catch (const Exception& e) {
             status = e.to_status();


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to