This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch clucene
in repository https://gitbox.apache.org/repos/asf/doris-thirdparty.git


The following commit(s) were added to refs/heads/clucene by this push:
     new d2b580f  [Update] do not read segment_N file when create new dir, 
because doris would never read an old index dir (#67)
d2b580f is described below

commit d2b580f35e87d5e9f6dd06c97bd22aba7770de27
Author: airborne12 <[email protected]>
AuthorDate: Tue May 16 17:12:24 2023 +0800

    [Update] do not read segment_N file when create new dir, because doris 
would never read an old index dir (#67)
---
 src/core/CLucene/index/IndexWriter.cpp   | 5 +++--
 src/core/CLucene/index/SDocumentWriter.h | 2 +-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/core/CLucene/index/IndexWriter.cpp 
b/src/core/CLucene/index/IndexWriter.cpp
index a2b3026..cdfebfa 100644
--- a/src/core/CLucene/index/IndexWriter.cpp
+++ b/src/core/CLucene/index/IndexWriter.cpp
@@ -261,13 +261,14 @@ void IndexWriter::init(Directory *d, Analyzer *a, const 
bool create, const bool
             // against an index that's currently open for
             // searching.  In this case we write the next
             // segments_N file with no segments:
-            try {
+            //NOTE: do not read when create, because doris would never read an 
old index dir
+            /*try {
                 segmentInfos->read(directory);
                 segmentInfos->clear();
             } catch (CLuceneError &e) {
                 if (e.number() != CL_ERR_IO) throw e;
                 // Likely this means it's a fresh directory
-            }
+            }*/
             segmentInfos->write(directory);
         } else {
             segmentInfos->read(directory);
diff --git a/src/core/CLucene/index/SDocumentWriter.h 
b/src/core/CLucene/index/SDocumentWriter.h
index 439a496..453cb6a 100644
--- a/src/core/CLucene/index/SDocumentWriter.h
+++ b/src/core/CLucene/index/SDocumentWriter.h
@@ -735,7 +735,7 @@ public:
     void abort(AbortException *ae) override {}
     void setMaxBufferedDocs(int32_t count) override {}
     void setInfoStream(std::ostream *is) override {
-        this->infoStream = infoStream;
+        this->infoStream = is;
     }
     void setRAMBufferSizeMB(float_t mb) override {
         if ((int32_t) mb == -1) {


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to