test

Author: sollhui

be/src/runtime/runtime_state.cpp

@@ -229,11 +229,9 @@ Status RuntimeState::init(const TUniqueId& fragment_instance_id, const TQueryOpt
         _query_options.max_errors = 100;
     }
 
-    LOG(INFO) << "batch size: " << _query_options.batch_size << ", query id: " << print_id(_query_id);
     if (_query_options.batch_size <= 0) {
         _query_options.batch_size = DEFAULT_BATCH_SIZE;
     }
-    LOG(INFO) << "batch size: " << _query_options.batch_size << ", query id: " << print_id(_query_id);
 
     _db_name = "insert_stmt";
     _import_label = print_id(fragment_instance_id);

fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadJob.java

@@ -307,6 +307,22 @@ private void createLoadingTask(Database db, BrokerPendingTaskAttachment attachme
                 }
                 boolean isEnableMemtableOnSinkNode =
                         table.getTableProperty().getUseSchemaLightChange() && this.enableMemTableOnSinkNode;
+                boolean hasInvertedIndexV1 = false;
+                if (table.getIndexes() != null) {
+                    for (org.apache.doris.catalog.Index index : table.getIndexes()) {
+                        if (index.getIndexType() == org.apache.doris.catalog.IndexDefinition.IndexType.INVERTED) {
+                            if (table.getInvertedIndexFileStorageFormat()
+                                    == org.apache.doris.thrift.TInvertedIndexFileStorageFormat.V1) {
+                                hasInvertedIndexV1 = true;
+                                break;
+                            }
+                        }
+                    }
+                }
+                if (isPartialUpdate() || hasInvertedIndexV1 || Config.isCloudMode()) {
+                    isEnableMemtableOnSinkNode = false;
+                }
+
                 // Generate loading task and init the plan of task
                 LoadLoadingTask task = createTask(db, table, brokerFileGroups,
                         isEnableMemtableOnSinkNode, batchSize, aggKey, attachment);