upd

Author: Mryange

be/src/vec/columns/column.cpp

@@ -43,6 +43,27 @@ std::string IColumn::dump_structure() const {
     return res.str();
 }
 
+int IColumn::count_const_column() const {
+    int count = is_column_const(*this) ? 1 : 0;
+    ColumnCallback callback = [&](ColumnPtr& subcolumn) {
+        if (is_column_const(*subcolumn)) {
+            count += 1;
+        }
+    };
+    // simply read using for_each_subcolumn without modification; const_cast can be used.
+    const_cast<IColumn*>(this)->for_each_subcolumn(callback);
+    return count;
+}
+
+bool IColumn::const_check() const {
+    auto const_cnt = count_const_column();
+    if (const_cnt == 0) {
+        return true;
+    }
+    // A const column is not allowed to be nested; it may only appear as the outermost (top-level) column.
+    return const_cnt == 1 && is_column_const(*this);
+}
+
 void IColumn::insert_from(const IColumn& src, size_t n) {
     insert(src[n]);
 }

be/src/vec/columns/column.h

@@ -647,6 +647,10 @@ class IColumn : public COW<IColumn> {
       */
     String dump_structure() const;
 
+    int count_const_column() const;
+
+    bool const_check() const;
+
     // only used in agg value replace for column which is not variable length, eg.BlockReader::_copy_value_data
     // usage: self_column.replace_column_data(other_column, other_column's row index, self_column's row index)
     virtual void replace_column_data(const IColumn&, size_t row, size_t self_row = 0) = 0;

be/src/vec/core/block.cpp

@@ -399,6 +399,12 @@ Status Block::check_type_and_column() const {
         const auto& type = elem.type;
         const auto& column = elem.column;
 
+        if (!column->const_check()) {
+            return Status::InternalError(
+                    "Column {} in block failed const check, data type :{} , column structure",
+                    elem.name, type->get_name(), column->dump_structure());
+        }
+
         auto st = type->check_column(*column);
         if (!st.ok()) {
             return Status::InternalError(