Return-Path: X-Original-To: apmail-lucene-java-user-archive@www.apache.org Delivered-To: apmail-lucene-java-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 5F0071024E for ; Mon, 21 Oct 2013 14:44:21 +0000 (UTC) Received: (qmail 36470 invoked by uid 500); 21 Oct 2013 14:44:16 -0000 Delivered-To: apmail-lucene-java-user-archive@lucene.apache.org Received: (qmail 36186 invoked by uid 500); 21 Oct 2013 14:44:08 -0000 Mailing-List: contact java-user-help@lucene.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: java-user@lucene.apache.org Delivered-To: mailing list java-user@lucene.apache.org Received: (qmail 36165 invoked by uid 99); 21 Oct 2013 14:44:06 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 21 Oct 2013 14:44:06 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of duke.dai.007@gmail.com designates 209.85.214.171 as permitted sender) Received: from [209.85.214.171] (HELO mail-ob0-f171.google.com) (209.85.214.171) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 21 Oct 2013 14:44:01 +0000 Received: by mail-ob0-f171.google.com with SMTP id wn1so4516164obc.2 for ; Mon, 21 Oct 2013 07:43:39 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=T8bzuD5bgEoRwc68OVrh/JOuKkPYooLT0S1z4FRBJgI=; b=06S2/GxeqOcMDuB82Nt/i8X/HL59tWPuuOa6wFzknE62iXS/ZjvnJySrS/FKy2SgrT JAIWsAr/kljh9tJpoTVuYucCx2dUtbJPwCH4iJZL+3bvYsek/6S6BrgXRi3Iqf9IUYx4 1Ij38671llUVZqaSnl95c2DpC15qoFBH8VanhD877F942IO0Q2jbEN6BmCu6iTL/ZUIz 6nI30lCaVCzrBThlBC+ZkORb+LYhEgeJfedhOws2xdiLpxVTfSEtEc4xL+vdnZzJE4vQ IcUFfHev+vqUYKKcWJTINK3QUP+XgbHooPMFyBl+q4CLd2OxoNhU+NIAdfCL+Wt1DzKI KYJA== MIME-Version: 1.0 X-Received: by 10.182.88.129 with SMTP id bg1mr5919105obb.36.1382366147601; Mon, 21 Oct 2013 07:35:47 -0700 (PDT) Received: by 10.182.18.99 with HTTP; Mon, 21 Oct 2013 07:35:47 -0700 (PDT) In-Reply-To: References: Date: Mon, 21 Oct 2013 22:35:47 +0800 Message-ID: Subject: Re: problem found with DiskDocValuesFormat From: Duke DAI To: java-user@lucene.apache.org Content-Type: multipart/alternative; boundary=089e01184a922d6c3b04e94133bb X-Virus-Checked: Checked by ClamAV on apache.org --089e01184a922d6c3b04e94133bb Content-Type: text/plain; charset=UTF-8 Hi Mike, My scenario, query thread from a ThreadPool will be used to execute query. So thread must have to be reused to handle various queries. Now that SegmentCoreReaders uses ThreadLocal to hold per-thread instance, I think some private variables must belong to the given thread(file offset? I didn't find any other thread-dependent status), otherwise object-level instance is enough. And ThreadPool is very common to facilitate heavy load queries, does the ThreadLocal mechanism support thread reuse for different queries? You know, either thread creation is heavy or ThreadLocal cleanup from outside is complicated. My test shows NumericDocValues will return wrong value, but sure that it's a long value, upper logic can verify whether the value is valid or not. As I described in earlier mail, in Lucene4.4 Lucene42DocValuesFormat(in-memory) has no problem, DiskDocValuesFormat(in-disk) has problem. Now in Lucene4.5, MemoryDocValuesFormat(in-memory) has no problem, but Lucene45DocValuesFormat(in-disk) has problem. Coincidency? My test is far more complex than I described, two ThreadPool, one is used to handle main query, one is used to query sub collections parallelly with proper RejectedExecutionHandler(now one sub rejected, cancel and fail all subs). For simple, what's the private status of per-thread NumericDocValues instance? The private status can be re-used for different queries? Best regards, Duke If not now, when? If not me, who? On Mon, Oct 21, 2013 at 7:26 PM, Michael McCandless < lucene@mikemccandless.com> wrote: > Can you describe what problem you are actually hitting? > > The purpose of docValuesLocal is to hold the per-Thread instance of > each doc values, and re-use it when that thread comes back again > asking for the same doc values. > > Mike McCandless > > http://blog.mikemccandless.com > > > On Mon, Oct 21, 2013 at 6:28 AM, Duke DAI wrote: > > Hi guys, > > > > Seems I have the same problem with Lucene45DocValuesFormat, no problem > with > > MemoryDocValuesFormat. The problem I encountered with Lucene4.4 is with > > DiskDocValuesFormat, no with Lucene42DocValuesFormat. > > > > I dig into a little and found the superficial cause. In > SegmentCoreReaders, > > there is a ThreadLocal variable, docValuesLocal. Its purpose is avoid > > building data structure repeatedly by query thread . But how about the > > query thread is from thread pool, and reused for different query? > > I removed docValuesLocal and built a lucene-core.jar, it works with my > > multi-threads(thread pool) test cases. > > > > Do you have any idea about this? Information is enough? > > > > > > Thanks, > > Duke > > > > > > Best regards, > > Duke > > If not now, when? If not me, who? > > > > > > On Tue, Aug 13, 2013 at 4:54 PM, Duke DAI > wrote: > > > >> Hi experts, > >> > >> I'm upgrading Lucene 4.4 and trying to use DocValues instead of store > >> field for performance reason. But due to unknown size of index(depends > on > >> customer), so I will use DiskDocValuesFormat, especially for some binary > >> field. Then I wrote my customized Codec: > >> > >> final Codec codec = new Lucene42Codec() { > >> > >> private final Lucene42DocValuesFormat memoryDVFormat = new > >> Lucene42DocValuesFormat(); > >> private final DiskDocValuesFormat diskDVFormat = new > >> DiskDocValuesFormat(); > >> > >> @Override > >> public DocValuesFormat getDocValuesFormatForField(String field) > { > >> if > >> (LucenePluginConstants.INDEX_STORED_RETURNABLE_FIELD.equals(field) > >> || LucenePluginConstants.PAYLOAD_FIELD_NAME.equals(field) > || > >> LucenePluginConstants.INDEX_NODE_ID_DOC_VALUE.equals(field)) { > >> return diskDVFormat; > >> } else { > >> return memoryDVFormat > >> } > >> } > >> }; > >> iwc.setCodec(codec); > >> > >> Here field LucenePluginConstants.INDEX_NODE_ID_DOC_VALUE is numeric > field, > >> long type. And others are binary. > >> > >> Then I consume DV like below pseudo-code: > >> nodeIDDocValuesSource = > >> MultiDocValues.getNumericValues(searcher.getIndexReader(), > >> LucenePluginConstants.INDEX_NODE_ID_DOC_VALUE); > >> > >> ...... > >> long nodeId= nodeIDDocValuesSource.get(scoreDoc.doc); > >> > >> Then I'm sure I get a wrong nodeId, which will be verified by upper > logic > >> and treated as data corruption. > >> > >> > >> But if I change to memoryDVFormat for the long type field, then > everything > >> is OK. > >> > >> Also for upgrading legacy data, I keep two index format, DV or stored > >> field, controlled by version. If I use stored field, everything is OK. > >> So I guess there is a bug with DiskDocValuesFormat, numeric data type, > >> does it relate to byte-aligned numeric compression? > >> Or I didn't use DiskDocValuesFormat correctly? Seems no other parameters > >> for it. > >> > >> Sorry that I have no pure Lucene test case yet. Hope someone shed some > >> light on this. > >> > >> > >> > >> > >> Best regards, > >> Duke > >> If not now, when? If not me, who? > >> > > --------------------------------------------------------------------- > To unsubscribe, e-mail: java-user-unsubscribe@lucene.apache.org > For additional commands, e-mail: java-user-help@lucene.apache.org > > --089e01184a922d6c3b04e94133bb--