diff --git a/lucene/src/java/org/apache/lucene/index/DocumentsWriterDeleteQueue.java b/lucene/src/java/org/apache/lucene/index/DocumentsWriterDeleteQueue.java index 2b9bd40542c..486c12659f7 100644 --- a/lucene/src/java/org/apache/lucene/index/DocumentsWriterDeleteQueue.java +++ b/lucene/src/java/org/apache/lucene/index/DocumentsWriterDeleteQueue.java @@ -83,7 +83,7 @@ final class DocumentsWriterDeleteQueue { this(new BufferedDeletes(false), generation); } - DocumentsWriterDeleteQueue(BufferedDeletes globalBufferedDeletes,long generation) { + DocumentsWriterDeleteQueue(BufferedDeletes globalBufferedDeletes, long generation) { this.globalBufferedDeletes = globalBufferedDeletes; this.generation = generation; /* diff --git a/lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThreadPool.java b/lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThreadPool.java index 83736f59749..611f5048283 100644 --- a/lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThreadPool.java +++ b/lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThreadPool.java @@ -61,7 +61,6 @@ public abstract class DocumentsWriterPerThreadPool { volatile boolean flushPending = false; // write access guarded by DocumentsWriterFlushControl long bytesUsed = 0; - // guarded by Reentrant lock private boolean isActive = true; @@ -131,8 +130,7 @@ public abstract class DocumentsWriterPerThreadPool { public DocumentsWriterPerThreadPool(int maxNumPerThreads) { maxNumPerThreads = (maxNumPerThreads < 1) ? IndexWriterConfig.DEFAULT_MAX_THREAD_STATES : maxNumPerThreads; - this.perThreads = new ThreadState[maxNumPerThreads]; - + perThreads = new ThreadState[maxNumPerThreads]; numThreadStatesActive = 0; }