[fix](inverted index) Ensure that col_unique_ids in TabletIndex are not empty.

be/src/olap/tablet_schema.h

@@ -41,6 +41,7 @@
 #include "runtime/define_primitive_type.h"
 #include "runtime/descriptors.h"
 #include "runtime/memory/lru_cache_policy.h"
+#include "util/debug_points.h"
 #include "util/string_util.h"
 #include "vec/aggregate_functions/aggregate_function.h"
 #include "vec/common/string_ref.h"
@@ -408,6 +409,12 @@ class TabletSchema : public MetadataAdder<TabletSchema> {
     }
     bool has_inverted_index() const {
         for (const auto& index : _indexes) {
+            DBUG_EXECUTE_IF("tablet_schema::has_inverted_index", {
+                if (index.col_unique_ids().empty()) {
+                    throw Exception(Status::InternalError("col unique ids cannot be empty"));
+                }
+            });
+
             if (index.index_type() == IndexType::INVERTED) {
                 //if index_id == -1, ignore it.
                 if (!index.col_unique_ids().empty() && index.col_unique_ids()[0] >= 0) {

fe/fe-core/src/main/java/org/apache/doris/catalog/Index.java

@@ -264,15 +264,14 @@ public TOlapTableIndex toThrift() {
         return tIndex;
     }
 
-    public OlapFile.TabletIndexPB toPb(List<Column> schemaColumns) {
+    public OlapFile.TabletIndexPB toPb(Map<Integer, Column> columnMap) {
         OlapFile.TabletIndexPB.Builder builder = OlapFile.TabletIndexPB.newBuilder();
         builder.setIndexId(indexId);
         builder.setIndexName(indexName);
-        for (String columnName : columns) {
-            for (Column column : schemaColumns) {
-                if (column.getName().equals(columnName)) {
-                    builder.addColUniqueId(column.getUniqueId());
-                }
+        for (Integer columnUniqueId : columnUniqueIds) {
+            Column column = columnMap.get(columnUniqueId);
+            if (column != null) {
+                builder.addColUniqueId(column.getUniqueId());
             }
         }
 

fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java

@@ -323,12 +323,17 @@ public OlapFile.TabletMetaCloudPB.Builder createTabletMetaBuilder(long tableId,
             schemaBuilder.addColumn(column.toPb(bfColumns, indexes));
         }
 
+        Map<Integer, Column> columnMap = Maps.newHashMap();
+        for (Column column : schemaColumns) {
+            columnMap.put(column.getUniqueId(), column);
+        }
         if (indexes != null) {
             for (int i = 0; i < indexes.size(); i++) {
                 Index index = indexes.get(i);
-                schemaBuilder.addIndex(index.toPb(schemaColumns));
+                schemaBuilder.addIndex(index.toPb(columnMap));
             }
         }
+
         if (rowStoreColumnUniqueIds != null) {
             schemaBuilder.addAllRowStoreColumnUniqueIds(rowStoreColumnUniqueIds);
         }

regression-test/suites/fault_injection_p0/test_index_ddl_fault_injection.groovy

@@ -18,10 +18,13 @@
 import org.codehaus.groovy.runtime.IOGroovyMethods
 
 suite("test_index_ddl_fault_injection", "nonConcurrent") {
+    def tableName1 = "test_index_ddl_fault_injection_tbl_1"
+    def tableName2 = "test_index_ddl_fault_injection_tbl_2"
+
     try {
-      sql "DROP TABLE IF EXISTS `test_index_ddl_fault_injection_tbl`"
+      sql "DROP TABLE IF EXISTS `${tableName1}`"
       sql """
-        CREATE TABLE test_index_ddl_fault_injection_tbl (
+        CREATE TABLE ${tableName1} (
           `k1` int(11) NULL COMMENT "",
           `k2` int(11) NULL COMMENT "",
           `v1` string NULL COMMENT ""
@@ -31,39 +34,69 @@ suite("test_index_ddl_fault_injection", "nonConcurrent") {
           PROPERTIES ( "replication_allocation" = "tag.location.default: 1");
       """
 
-      sql """ INSERT INTO test_index_ddl_fault_injection_tbl VALUES (1, 2, "hello"), (3, 4, "world"); """
+      sql """ INSERT INTO ${tableName1} VALUES (1, 2, "hello"), (3, 4, "world"); """
       sql 'sync'
 
-      qt_order1 """ select * from test_index_ddl_fault_injection_tbl where v1 = 'hello'; """
+      qt_order1 """ select * from ${tableName1} where v1 = 'hello'; """
 
       // add bloom filter
-      sql """ ALTER TABLE test_index_ddl_fault_injection_tbl set ("bloom_filter_columns" = "v1"); """
-      assertEquals("FINISHED", getAlterColumnFinalState("test_index_ddl_fault_injection_tbl"))
+      sql """ ALTER TABLE ${tableName1} set ("bloom_filter_columns" = "v1"); """
+      assertEquals("FINISHED", getAlterColumnFinalState("${tableName1}"))
 
       try {
-          qt_order2 """ select * from test_index_ddl_fault_injection_tbl where v1 = 'hello'; """
+          qt_order2 """ select * from ${tableName1} where v1 = 'hello'; """
           GetDebugPoint().enableDebugPointForAllBEs("BloomFilterIndexReader::new_iterator.fail");
           test {
             // if BE add bloom filter correctly, this query will call BloomFilterIndexReader::new_iterator
-            sql """ select * from test_index_ddl_fault_injection_tbl where v1 = 'hello'; """
+            sql """ select * from ${tableName1} where v1 = 'hello'; """
            exception "new_iterator for bloom filter index failed"
           }
       } finally {
           GetDebugPoint().disableDebugPointForAllBEs("BloomFilterIndexReader::new_iterator.fail");
       }
 
       // drop bloom filter
-      sql """ ALTER TABLE test_index_ddl_fault_injection_tbl set ("bloom_filter_columns" = ""); """
-      assertEquals("FINISHED", getAlterColumnFinalState("test_index_ddl_fault_injection_tbl"))
+      sql """ ALTER TABLE ${tableName1} set ("bloom_filter_columns" = ""); """
+      assertEquals("FINISHED", getAlterColumnFinalState("${tableName1}"))
 
       try {
-          qt_order3 """ select * from test_index_ddl_fault_injection_tbl where v1 = 'hello'; """
+          qt_order3 """ select * from ${tableName1} where v1 = 'hello'; """
           GetDebugPoint().enableDebugPointForAllBEs("BloomFilterIndexReader::new_iterator.fail");
             // if BE drop bloom filter correctly, this query will not call BloomFilterIndexReader::new_iterator
-          qt_order4 """ select * from test_index_ddl_fault_injection_tbl where v1 = 'hello'; """
+          qt_order4 """ select * from ${tableName1} where v1 = 'hello'; """
       } finally {
           GetDebugPoint().disableDebugPointForAllBEs("BloomFilterIndexReader::new_iterator.fail");
       }
     } finally {
     }
+
+    sql "DROP TABLE IF EXISTS `${tableName2}`"
+    sql """
+        CREATE TABLE `${tableName2}` (
+          `col0` bigint NOT NULL,
+          `col1` boolean NULL,
+          `col2` tinyint NOT NULL,
+          INDEX col1 (`col1`) USING INVERTED,
+          INDEX col2 (`col2`) USING INVERTED
+        ) ENGINE=OLAP
+        UNIQUE KEY(`col0`)
+        DISTRIBUTED BY HASH(`col0`) BUCKETS 1
+        PROPERTIES (
+        "enable_unique_key_merge_on_write" = "true", 
+        "store_row_column" = "true",
+        "replication_num" = "1"
+        );
+    """
+
+    try {
+        sql """ INSERT INTO ${tableName2} (col0, col1, col2) VALUES (-74, true, 1); """
+        sql 'sync'
+
+        GetDebugPoint().enableDebugPointForAllBEs("tablet_schema::has_inverted_index");
+
+        sql """ ALTER TABLE ${tableName2} MODIFY COLUMN col1 BOOLEAN; """
+        assertEquals("FINISHED", getAlterColumnFinalState("${tableName2}"))
+    } finally {
+        GetDebugPoint().disableDebugPointForAllBEs("tablet_schema::has_inverted_index");
+    }
 }