You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by dn...@apache.org on 2021/07/28 14:05:13 UTC

[lucene] branch main updated: LUCENE-9304: Remove assertion in DocumentsWriterFlushControl (#228)

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

dnhatn pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/lucene.git


The following commit(s) were added to refs/heads/main by this push:
     new 03b1db9  LUCENE-9304: Remove assertion in DocumentsWriterFlushControl (#228)
03b1db9 is described below

commit 03b1db91f9e5b11816274efd0da8503db27ccce0
Author: Shintaro Murakami <mr...@gmail.com>
AuthorDate: Wed Jul 28 23:05:00 2021 +0900

    LUCENE-9304: Remove assertion in DocumentsWriterFlushControl (#228)
    
    This is assertion becomes obvious after LUCENE-9304.
---
 .../org/apache/lucene/index/DocumentsWriterFlushControl.java   | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java b/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
index 20916b5..0dd39c3 100644
--- a/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
+++ b/lucene/core/src/java/org/apache/lucene/index/DocumentsWriterFlushControl.java
@@ -552,16 +552,6 @@ final class DocumentsWriterFlushControl implements Accountable, Closeable {
     for (final DocumentsWriterPerThread next :
         perThreadPool.filterAndLock(dwpt -> dwpt.deleteQueue == flushingQueue)) {
       try {
-        assert next.deleteQueue == flushingQueue || next.deleteQueue == documentsWriter.deleteQueue
-            : " flushingQueue: "
-                + flushingQueue
-                + " currentqueue: "
-                + documentsWriter.deleteQueue
-                + " perThread queue: "
-                + next.deleteQueue
-                + " numDocsInRam: "
-                + next.getNumDocsInRAM();
-
         if (next.getNumDocsInRAM() > 0) {
           final DocumentsWriterPerThread flushingDWPT;
           synchronized (this) {