Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 48EB1200AC8 for ; Tue, 7 Jun 2016 18:16:23 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 47B21160A57; Tue, 7 Jun 2016 16:16:23 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 8F23E160968 for ; Tue, 7 Jun 2016 18:16:22 +0200 (CEST) Received: (qmail 96831 invoked by uid 500); 7 Jun 2016 16:16:21 -0000 Mailing-List: contact dev-help@lucene.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@lucene.apache.org Delivered-To: mailing list dev@lucene.apache.org Received: (qmail 96755 invoked by uid 99); 7 Jun 2016 16:16:21 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 07 Jun 2016 16:16:21 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 1D4922C1F68 for ; Tue, 7 Jun 2016 16:16:21 +0000 (UTC) Date: Tue, 7 Jun 2016 16:16:21 +0000 (UTC) From: "Noble Paul (JIRA)" To: dev@lucene.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (SOLR-9191) OverseerTaskQueue.peekTopN() fatally flawed MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Tue, 07 Jun 2016 16:16:23 -0000 [ https://issues.apache.org/jira/browse/SOLR-9191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318782#comment-15318782 ] Noble Paul commented on SOLR-9191: ---------------------------------- Is there a way we can avoid reading the "already read" items from ZK? > OverseerTaskQueue.peekTopN() fatally flawed > ------------------------------------------- > > Key: SOLR-9191 > URL: https://issues.apache.org/jira/browse/SOLR-9191 > Project: Solr > Issue Type: Bug > Affects Versions: 5.4, 5.4.1, 5.5, 5.5.1, 6.0, 6.0.1 > Reporter: Scott Blum > Assignee: Scott Blum > Original Estimate: 24h > Remaining Estimate: 24h > > We rewrote DistributedQueue in SOLR-6760, to optimize its obvious use case as a FIFO. But in doing so, we broke the assumptions in OverseerTaskQueue.peekTopN().. > OverseerTaskQueue.peekTopN() involves filtering out items you're already working on, it's trying to peek for new items in the queue beyond what you already know about. But DistributedQueue (being designed as a FIFO) doesn't know about the filtering; as long as it has any items in-memory it just keeps returning those over and over without ever pulling new data from ZK. This is true even if the watcher has fired and marked the state as dirty. So OverseerTaskQueue gets into a state where it can never read new items in ZK because DQ keeps returning the same items that it has marked as in-progress. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscribe@lucene.apache.org For additional commands, e-mail: dev-help@lucene.apache.org