diff --git a/src/coprocessor/coprocessor_v2.cc b/src/coprocessor/coprocessor_v2.cc index 270974bcb..3d35673cb 100755 --- a/src/coprocessor/coprocessor_v2.cc +++ b/src/coprocessor/coprocessor_v2.cc @@ -38,7 +38,8 @@ namespace dingodb { -DEFINE_bool(enable_coprocessor_v2_statistics_time_consumption, false, "enable coprocessor_v2 statistics time consumption default is false"); +DEFINE_bool(enable_coprocessor_v2_statistics_time_consumption, false, + "enable coprocessor_v2 statistics time consumption default is false"); bvar::Adder CoprocessorV2::bvar_coprocessor_v2_object_running_num("dingo_coprocessor_v2_object_running_num"); bvar::Adder CoprocessorV2::bvar_coprocessor_v2_object_total_num("dingo_coprocessor_v2_object_total_num"); @@ -551,7 +552,8 @@ butil::Status CoprocessorV2::DoRelExprCoreWrapper(const std::string& key, const int ret = 0; try { // decode some column. not decode all - ret = original_record_decoder_->Decode(key, value, selection_column_indexes_, original_record); + ret = original_record_decoder_->Decode(key, value, selection_column_indexes_, selection_column_indexes_serial_, + original_record); } catch (const std::exception& my_exception) { std::string error_message = fmt::format("serial::Decode failed exception : {}", my_exception.what()); DINGO_LOG(ERROR) << error_message; diff --git a/src/engine/rocks_raw_engine.cc b/src/engine/rocks_raw_engine.cc index f3200fd03..95e6ca54c 100644 --- a/src/engine/rocks_raw_engine.cc +++ b/src/engine/rocks_raw_engine.cc @@ -914,6 +914,7 @@ rocksdb::DB* RocksRawEngine::InitDB(const std::string& db_path, rocks::ColumnFam db_options.max_subcompactions = db_options.max_background_jobs / 4 * 3; db_options.stats_dump_period_sec = ConfigHelper::GetRocksDBStatsDumpPeriodSec(); db_options.use_direct_io_for_flush_and_compaction = true; + db_options.statistics=rocksdb::CreateDBStatistics(); DINGO_LOG(INFO) << fmt::format("[rocksdb] config max_background_jobs({}) max_subcompactions({})", db_options.max_background_jobs, db_options.max_subcompactions);