diff --git a/rag/svr/task_executor.py b/rag/svr/task_executor.py
index 7af52adf8e..4b8a272891 100644
--- a/rag/svr/task_executor.py
+++ b/rag/svr/task_executor.py
@@ -897,7 +897,7 @@ async def insert_chunks(task_id, task_tenant_id, task_dataset_id, chunks, progre
         flds = list(mom_ck.keys())
         for fld in flds:
             if fld not in ["id", "content_with_weight", "doc_id", "docnm_kwd", "kb_id", "available_int",
-                           "position_int"]:
+                           "position_int", "create_timestamp_flt", "page_num_int", "top_int"]:
                 del mom_ck[fld]
         mothers.append(mom_ck)
 
diff --git a/rag/utils/ob_conn.py b/rag/utils/ob_conn.py
index e20f8993ec..1ee47aceb8 100644
--- a/rag/utils/ob_conn.py
+++ b/rag/utils/ob_conn.py
@@ -986,7 +986,7 @@ class OBConnection(OBConnectionBase):
                     for field, order in order_by.fields:
                         if isinstance(column_types[field], ARRAY):
                             f = field + "_sort"
-                            fields_expr += f", array_to_string({field}, ',') AS {f}"
+                            fields_expr += f", array_avg({field}) AS {f}"
                             field = f
                         order = "ASC" if order == 0 else "DESC"
                         orders.append(f"{field} {order}")