Return-Path: X-Original-To: apmail-flink-issues-archive@minotaur.apache.org Delivered-To: apmail-flink-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1673517571 for ; Mon, 20 Oct 2014 14:51:58 +0000 (UTC) Received: (qmail 97869 invoked by uid 500); 20 Oct 2014 14:51:58 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 97836 invoked by uid 500); 20 Oct 2014 14:51:57 -0000 Mailing-List: contact issues-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list issues@flink.incubator.apache.org Received: (qmail 97827 invoked by uid 99); 20 Oct 2014 14:51:57 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Oct 2014 14:51:57 +0000 X-ASF-Spam-Status: No, hits=-2001.4 required=5.0 tests=ALL_TRUSTED,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; Mon, 20 Oct 2014 14:51:36 +0000 Received: (qmail 97298 invoked by uid 99); 20 Oct 2014 14:51:34 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Oct 2014 14:51:34 +0000 Date: Mon, 20 Oct 2014 14:51:33 +0000 (UTC) From: "Gyula Fora (JIRA)" To: issues@flink.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Closed] (FLINK-1160) Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader 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 [ https://issues.apache.org/jira/browse/FLINK-1160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1160. ----------------------------- > Modify record readers to allow publishing events to specific inputs (instead of broadcast) in the union record reader > --------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-1160 > URL: https://issues.apache.org/jira/browse/FLINK-1160 > Project: Flink > Issue Type: Improvement > Components: Distributed Runtime, Streaming > Reporter: Gyula Fora > Assignee: Gyula Fora > Priority: Minor > > In order to do efficient record acknowledgments for fault tolerance we need to modify record readers to allow publishing events to specific inputs in the union record reader. Currently only broadcasting is supported for all inputs which is unnecessary for the acknowledgements and poses significant network overhead. -- This message was sent by Atlassian JIRA (v6.3.4#6332)