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 790A218D02 for ; Fri, 26 Jun 2015 20:32:05 +0000 (UTC) Received: (qmail 93406 invoked by uid 500); 26 Jun 2015 20:32:05 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 93263 invoked by uid 500); 26 Jun 2015 20:32:05 -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 93096 invoked by uid 99); 26 Jun 2015 20:32:05 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 26 Jun 2015 20:32:05 +0000 Date: Fri, 26 Jun 2015 20:32:05 +0000 (UTC) From: "Gyula Fora (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-2281) Allow chaining of operators with multiple inputs MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 Gyula Fora created FLINK-2281: --------------------------------- Summary: Allow chaining of operators with multiple inputs Key: FLINK-2281 URL: https://issues.apache.org/jira/browse/FLINK-2281 Project: Flink Issue Type: Improvement Components: Streaming Reporter: Gyula Fora Assignee: Gyula Fora Priority: Minor Currently only operators with one input can be chained for better performance. In principle there is no reason why this should not be extended to multiple input operators (where chaining is applicable, i.e forward connected), to allow maximal speedup. The concern usually arises that it might not be good to always chain everything in case of computation heavy operators. In these cases (if the job is otherwise viable) chaining only increases latency for some operations while the throughput is increased exploiting by increasing the parallelism to the freed resources. In any case chaining should still remain tunable on an operator level. -- This message was sent by Atlassian JIRA (v6.3.4#6332)