diff --git a/src/storage/ddl/ob_direct_insert_sstable_ctx_new.cpp b/src/storage/ddl/ob_direct_insert_sstable_ctx_new.cpp index 94d57621be..cdca9e8c70 100644 --- a/src/storage/ddl/ob_direct_insert_sstable_ctx_new.cpp +++ b/src/storage/ddl/ob_direct_insert_sstable_ctx_new.cpp @@ -1279,6 +1279,7 @@ int ObTabletDirectLoadMgr::prepare_schema_item_on_demand(const uint64_t table_id schema_item_.is_index_table_ = table_schema->is_index_table(); schema_item_.rowkey_column_num_ = table_schema->get_rowkey_column_num(); schema_item_.is_unique_index_ = table_schema->is_unique_index(); + schema_item_.lob_inrow_threshold_ = table_schema->get_lob_inrow_threshold(); if (OB_FAIL(column_items_.reserve(data_desc.get_col_desc_array().count()))) { LOG_WARN("reserve column schema array failed", K(ret), K(data_desc.get_col_desc_array().count()), K(column_items_)); diff --git a/src/storage/lob/ob_lob_util.cpp b/src/storage/lob/ob_lob_util.cpp index 400b2d2c02..d83a001a3b 100644 --- a/src/storage/lob/ob_lob_util.cpp +++ b/src/storage/lob/ob_lob_util.cpp @@ -239,7 +239,7 @@ int ObInsertLobColumnHelper::insert_lob_column(ObIAllocator &allocator, int64_t byte_len = 0; if (OB_FAIL(src.get_lob_data_byte_len(byte_len))) { LOG_WARN("fail to get lob data byte len", K(ret), K(src)); - } else if (src.has_inrow_data() && byte_len <= ObLobManager::LOB_IN_ROW_MAX_LENGTH) { + } else if (src.has_inrow_data() && lob_mngr->can_write_inrow(data.length(), lob_storage_param.inrow_threshold_)) { // do fast inrow if (OB_FAIL(src.get_inrow_data(data))) { LOG_WARN("fail to get inrow data", K(ret), K(src));