diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp
index 16b75794511c06..47b007edf5dc9b 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -1292,8 +1292,8 @@ Status FragmentMgr::sync_filter_size(const PSyncFilterSizeRequest* request) {
         if (auto q_ctx = _get_or_erase_query_ctx(query_id)) {
             query_ctx = q_ctx;
         } else {
-            return Status::InvalidArgument(
-                    "Sync filter size failed: Query context (query-id: {}) not found",
+            return Status::EndOfFile(
+                    "Sync filter size failed: Query context (query-id: {}) already finished",
                     queryid.to_string());
         }
     }
@@ -1313,8 +1313,8 @@ Status FragmentMgr::merge_filter(const PMergeFilterRequest* request,
         if (auto q_ctx = _get_or_erase_query_ctx(query_id)) {
             query_ctx = q_ctx;
         } else {
-            return Status::InvalidArgument(
-                    "Merge filter size failed: Query context (query-id: {}) not found",
+            return Status::EndOfFile(
+                    "Merge filter size failed: Query context (query-id: {}) already finished",
                     queryid.to_string());
         }
     }