Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-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 B024817FD9 for ; Tue, 10 Feb 2015 09:04:56 +0000 (UTC) Received: (qmail 88290 invoked by uid 500); 10 Feb 2015 09:04:56 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 88180 invoked by uid 500); 10 Feb 2015 09:04:56 -0000 Mailing-List: contact dev-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 dev@flink.apache.org Received: (qmail 88159 invoked by uid 99); 10 Feb 2015 09:04:56 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Feb 2015 09:04:56 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Tue, 10 Feb 2015 09:04:55 +0000 Received: (qmail 87855 invoked by uid 99); 10 Feb 2015 09:04:35 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Feb 2015 09:04:35 +0000 Date: Tue, 10 Feb 2015 09:04:35 +0000 (UTC) From: "Ufuk Celebi (JIRA)" To: dev@flink.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-1505) Separate buffer reader and channel consumption logic MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org Ufuk Celebi created FLINK-1505: ---------------------------------- Summary: Separate buffer reader and channel consumption logic Key: FLINK-1505 URL: https://issues.apache.org/jira/browse/FLINK-1505 Project: Flink Issue Type: Improvement Components: Distributed Runtime Affects Versions: master Reporter: Ufuk Celebi Priority: Minor Currently, the hierarchy of readers (f.a.o.runtime.io.network.api) is bloated. There is no separation between consumption of the input channels and the buffer readers. This was not the case up until release-0.8 and has been introduced by me with intermediate results. I think this was a mistake and we should seperate this again. flink-streaming is currently the heaviest user of these lower level APIs and I have received feedback from [~gyfora] to undo this as well. -- This message was sent by Atlassian JIRA (v6.3.4#6332)