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 4D8CE200BEC for ; Thu, 15 Dec 2016 06:59:00 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 4C2C6160B34; Thu, 15 Dec 2016 05:59:00 +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 8CCF7160B19 for ; Thu, 15 Dec 2016 06:58:59 +0100 (CET) Received: (qmail 44631 invoked by uid 500); 15 Dec 2016 05:58:58 -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 44605 invoked by uid 99); 15 Dec 2016 05:58:58 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 15 Dec 2016 05:58:58 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 727012C0057 for ; Thu, 15 Dec 2016 05:58:58 +0000 (UTC) Date: Thu, 15 Dec 2016 05:58:58 +0000 (UTC) From: "godfrey he (JIRA)" To: dev@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (FLINK-5342) Setting the parallelism automatically for DataSet Operators base on cost model MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Thu, 15 Dec 2016 05:59:00 -0000 godfrey he created FLINK-5342: --------------------------------- Summary: Setting the parallelism automatically for DataSet Operators base on cost model Key: FLINK-5342 URL: https://issues.apache.org/jira/browse/FLINK-5342 Project: Flink Issue Type: Improvement Components: Table API & SQL Reporter: godfrey he On Flink table API, a query will be translate to operators without parallelism. And user do not know the target operators translated from query, and can not set parallelism. So it's better to set the parallelism automatically for each operator base on cost model. -- This message was sent by Atlassian JIRA (v6.3.4#6332)