| Index: lucene/src/java/org/apache/lucene/index/DocumentsWriter.java |
| =================================================================== |
| --- lucene/src/java/org/apache/lucene/index/DocumentsWriter.java (revision 1100130) |
| +++ lucene/src/java/org/apache/lucene/index/DocumentsWriter.java (working copy) |
| @@ -188,7 +188,7 @@ |
| this.infoStream = infoStream; |
| final Iterator<ThreadState> it = perThreadPool.getAllPerThreadsIterator(); |
| while (it.hasNext()) { |
| - it.next().perThread.docState.infoStream = infoStream; |
| + it.next().perThread.setInfoStream(infoStream); |
| } |
| } |
| |
| Index: lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThread.java |
| =================================================================== |
| --- lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThread.java (revision 1100130) |
| +++ lucene/src/java/org/apache/lucene/index/DocumentsWriterPerThread.java (working copy) |
| @@ -163,7 +163,7 @@ |
| boolean hasAborted = false; // True if the last exception throws by #updateDocument was aborting |
| |
| private FieldInfos fieldInfos; |
| - private final PrintStream infoStream; |
| + private PrintStream infoStream; |
| private int numDocsInRAM; |
| private int flushedDocCount; |
| DocumentsWriterDeleteQueue deleteQueue; |
| @@ -493,4 +493,9 @@ |
| } |
| |
| }; |
| + |
| + void setInfoStream(PrintStream infoStream) { |
| + this.infoStream = infoStream; |
| + docState.infoStream = infoStream; |
| + } |
| } |
