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 C255F200BDB for ; Mon, 12 Dec 2016 13:20:59 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id C0D5B160B22; Mon, 12 Dec 2016 12:20:59 +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 3B85F160B0D for ; Mon, 12 Dec 2016 13:20:59 +0100 (CET) Received: (qmail 44791 invoked by uid 500); 12 Dec 2016 12:20:58 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 44769 invoked by uid 99); 12 Dec 2016 12:20:58 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Dec 2016 12:20:58 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 53F582C0086 for ; Mon, 12 Dec 2016 12:20:58 +0000 (UTC) Date: Mon, 12 Dec 2016 12:20:58 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-5088) Add option to limit subpartition queue length MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Mon, 12 Dec 2016 12:20:59 -0000 [ https://issues.apache.org/jira/browse/FLINK-5088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15741765#comment-15741765 ] ASF GitHub Bot commented on FLINK-5088: --------------------------------------- Github user uce commented on the issue: https://github.com/apache/flink/pull/2883 @StephanEwen I think we're going to leave this out of the upcoming 1.2 release after all. From cluster tests it seems like it didn't help as much as we wanted. What do you think? > Add option to limit subpartition queue length > --------------------------------------------- > > Key: FLINK-5088 > URL: https://issues.apache.org/jira/browse/FLINK-5088 > Project: Flink > Issue Type: Improvement > Components: Network > Affects Versions: 1.1.3 > Reporter: Ufuk Celebi > Assignee: Ufuk Celebi > > Currently the sub partition queues are not bounded. Queued buffers are consumed by the network event loop or local consumers. -- This message was sent by Atlassian JIRA (v6.3.4#6332)