You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by yu...@apache.org on 2022/01/11 09:01:05 UTC
[incubator-pegasus] branch master updated: feat(online_migration): update log to print ingest_behind option (#878)
This is an automated email from the ASF dual-hosted git repository.
yuchenhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new dc92826 feat(online_migration): update log to print ingest_behind option (#878)
dc92826 is described below
commit dc9282625a5ae6cc8fb94fa5ef5f1c89a6d5b633
Author: HeYuchen <he...@xiaomi.com>
AuthorDate: Tue Jan 11 16:57:19 2022 +0800
feat(online_migration): update log to print ingest_behind option (#878)
---
src/server/rocksdb_wrapper.cpp | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git a/src/server/rocksdb_wrapper.cpp b/src/server/rocksdb_wrapper.cpp
index ed52631..e9131e2 100644
--- a/src/server/rocksdb_wrapper.cpp
+++ b/src/server/rocksdb_wrapper.cpp
@@ -189,9 +189,16 @@ int rocksdb_wrapper::ingest_files(int64_t decree,
ifo.ingest_behind = ingest_behind;
rocksdb::Status s = _db->IngestExternalFile(sst_file_list, ifo);
if (dsn_unlikely(!s.ok())) {
- derror_rocksdb("IngestExternalFile", s.ToString(), "decree = {}", decree);
+ derror_rocksdb("IngestExternalFile",
+ s.ToString(),
+ "decree = {}, ingest_behind = {}",
+ decree,
+ ingest_behind);
} else {
- ddebug_rocksdb("IngestExternalFile", "Ingest files succeed, decree = {}", decree);
+ ddebug_rocksdb("IngestExternalFile",
+ "Ingest files succeed, decree = {}, ingest_behind = {}",
+ decree,
+ ingest_behind);
}
return s.code();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org