From 847db2c0157e045d9671b7e5bba67eb2270efb83 Mon Sep 17 00:00:00 2001 From: abmdocrt Date: Tue, 6 Feb 2024 10:09:20 +0800 Subject: [PATCH] [Enhancement](group commit) Add retry message for group commit load while schema changing (#30391) --- be/src/runtime/group_commit_mgr.cpp | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/be/src/runtime/group_commit_mgr.cpp b/be/src/runtime/group_commit_mgr.cpp index 88a8150a60..20872eb59d 100644 --- a/be/src/runtime/group_commit_mgr.cpp +++ b/be/src/runtime/group_commit_mgr.cpp @@ -206,7 +206,9 @@ Status GroupCommitTable::get_first_block_load_queue( } } if (!is_schema_version_match) { - return Status::DataQualityError("schema version not match"); + return Status::DataQualityError( + "schema version not match, maybe a schema change is in process. Please " + "retry this load manually."); } if (!_need_plan_fragment) { _need_plan_fragment = true; @@ -222,7 +224,9 @@ Status GroupCommitTable::get_first_block_load_queue( return Status::OK(); } } else if (base_schema_version < load_block_queue->schema_version) { - return Status::DataQualityError("schema version not match"); + return Status::DataQualityError( + "schema version not match, maybe a schema change is in process. Please " + "retry this load manually."); } load_block_queue.reset(); }