From dev-return-9920-apmail-drill-dev-archive=drill.apache.org@drill.apache.org Mon Jan 5 01:09:34 2015 Return-Path: X-Original-To: apmail-drill-dev-archive@www.apache.org Delivered-To: apmail-drill-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id ED1FD10362 for ; Mon, 5 Jan 2015 01:09:33 +0000 (UTC) Received: (qmail 55920 invoked by uid 500); 5 Jan 2015 01:09:34 -0000 Delivered-To: apmail-drill-dev-archive@drill.apache.org Received: (qmail 55855 invoked by uid 500); 5 Jan 2015 01:09:34 -0000 Mailing-List: contact dev-help@drill.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@drill.apache.org Delivered-To: mailing list dev@drill.apache.org Received: (qmail 55808 invoked by uid 99); 5 Jan 2015 01:09:34 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 05 Jan 2015 01:09:34 +0000 Date: Mon, 5 Jan 2015 01:09:34 +0000 (UTC) From: "Yuliya Feldman (JIRA)" To: dev@drill.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (DRILL-1926) Fix back pressure logic MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Yuliya Feldman created DRILL-1926: ------------------------------------- Summary: Fix back pressure logic Key: DRILL-1926 URL: https://issues.apache.org/jira/browse/DRILL-1926 Project: Apache Drill Issue Type: Bug Components: Execution - Flow Reporter: Yuliya Feldman Assignee: Yuliya Feldman While enqueueing coming requests in UnlimitedRawBatchBuffer replies to the sender(s) will queue up only if size of the queue is equal to soft limit and not when it is >= softlimit - which means it will work only once, while requests will be piling up. Also improving logic of sending responses back to the senders by not just sending them in one shot that can create flood of requests again, but in batches based on difference between softlimit and queue size -- This message was sent by Atlassian JIRA (v6.3.4#6332)