diff options
author | Tor Egge <Tor.Egge@broadpark.no> | 2021-01-07 11:24:02 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@broadpark.no> | 2021-01-07 11:24:02 +0100 |
commit | 3f82507f55cd98baeca7e2d098b46a75166549b8 (patch) | |
tree | 06e6a55289ef353c474a15f6c619bdd41833c318 | |
parent | e096765acfc1b28e6bce7855d7450824e4d287bb (diff) |
Extend log messages when fusion fails or is stopped with fusion dir.
-rw-r--r-- | searchcorespi/src/vespa/searchcorespi/index/indexmaintainer.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/searchcorespi/src/vespa/searchcorespi/index/indexmaintainer.cpp b/searchcorespi/src/vespa/searchcorespi/index/indexmaintainer.cpp index 9c180c39144..38990f61b43 100644 --- a/searchcorespi/src/vespa/searchcorespi/index/indexmaintainer.cpp +++ b/searchcorespi/src/vespa/searchcorespi/index/indexmaintainer.cpp @@ -989,10 +989,11 @@ IndexMaintainer::doFusion(SerialNum serialNum, std::shared_ptr<search::IFlushTok LockGuard lock(_fusion_lock); if (new_fusion_id == spec.last_fusion_id) { // Error running fusion. + string fail_dir = getFusionDir(spec.flush_ids.back()); if (flush_token->stop_requested()) { - LOG(info, "Fusion stopped for id %u.", spec.flush_ids.back()); + LOG(info, "Fusion stopped for id %u, fusion dir \"%s\".", spec.flush_ids.back(), fail_dir.c_str()); } else { - LOG(warning, "Fusion failed for id %u.", spec.flush_ids.back()); + LOG(warning, "Fusion failed for id %u, fusion dir \"%s\".", spec.flush_ids.back(), fail_dir.c_str()); } // Restore fusion spec. copy(_fusion_spec.flush_ids.begin(), _fusion_spec.flush_ids.end(), back_inserter(spec.flush_ids)); @@ -1032,12 +1033,12 @@ IndexMaintainer::runFusion(const FusionSpec &fusion_spec, std::shared_ptr<search getFusionDir(new_fusion_id)); } if (!ok) { + string fail_dir = getFusionDir(fusion_spec.flush_ids.back()); if (flush_token->stop_requested()) { - LOG(info, "Fusion stopped."); + LOG(info, "Fusion stopped, fusion dir \"%s\".", fail_dir.c_str()); } else { - LOG(error, "Fusion failed."); + LOG(error, "Fusion failed, fusion dir \"%s\".", fail_dir.c_str()); } - string fail_dir = getFusionDir(fusion_spec.flush_ids.back()); FastOS_FileInterface::EmptyAndRemoveDirectory(fail_dir.c_str()); { LockGuard slock(_state_lock); |