This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-1.1-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.1-lts by this push:
new c87f3a477c [fix](load) fix that flush memtable concurrently may cause
data inconsistency (#15028)
c87f3a477c is described below
commit c87f3a477ca68706d6b8ad205c6950089e2d279e
Author: Xin Liao <[email protected]>
AuthorDate: Thu Dec 15 20:43:34 2022 +0800
[fix](load) fix that flush memtable concurrently may cause data
inconsistency (#15028)
---
be/src/olap/memtable_flush_executor.cpp | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/be/src/olap/memtable_flush_executor.cpp
b/be/src/olap/memtable_flush_executor.cpp
index 0a9ad6242e..4158f1d51e 100644
--- a/be/src/olap/memtable_flush_executor.cpp
+++ b/be/src/olap/memtable_flush_executor.cpp
@@ -69,7 +69,11 @@ void FlushToken::_flush_memtable(std::shared_ptr<MemTable>
memtable, int64_t sub
MonotonicStopWatch timer;
timer.start();
- _flush_status.store(memtable->flush());
+ OLAPStatus s = memtable->flush();
+ if (s != OLAP_SUCCESS) {
+ LOG(WARNING) << "Flush memtable failed with res = " << s;
+ _flush_status.store(s);
+ }
if (_flush_status.load() != OLAP_SUCCESS) {
return;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
