diff --git a/be/src/olap/wal/wal_manager.cpp b/be/src/olap/wal/wal_manager.cpp index 601a9bc5b4..59e87fba9c 100644 --- a/be/src/olap/wal/wal_manager.cpp +++ b/be/src/olap/wal/wal_manager.cpp @@ -403,6 +403,7 @@ Status WalManager::_update_wal_dir_info_thread() { while (!_stop.load()) { static_cast(_wal_dirs_info->update_all_wal_dir_limit()); static_cast(_wal_dirs_info->update_all_wal_dir_used()); + LOG_EVERY_N(INFO, 100) << "Scheduled(every 10s) WAL info: " << get_wal_dirs_info_string(); std::this_thread::sleep_for(std::chrono::milliseconds(100)); } return Status::OK(); diff --git a/be/src/runtime/group_commit_mgr.cpp b/be/src/runtime/group_commit_mgr.cpp index d98bf9efd1..b793efa6e7 100644 --- a/be/src/runtime/group_commit_mgr.cpp +++ b/be/src/runtime/group_commit_mgr.cpp @@ -420,7 +420,9 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t db_id, int64_t table_ << ", txn_id=" << txn_id << ", instance_id=" << print_id(instance_id) << ", exec_plan_fragment status=" << status.to_string() << ", commit/abort txn rpc status=" << st.to_string() - << ", commit/abort txn status=" << result_status.to_string(); + << ", commit/abort txn status=" << result_status.to_string() + << ", block queue pre allocated size is " << load_block_queue->block_queue_pre_allocated() + << ", wal space info:" << ExecEnv::GetInstance()->wal_mgr()->get_wal_dirs_info_string(); if (state) { if (!state->get_error_log_file_path().empty()) { ss << ", error_url=" << state->get_error_log_file_path();