flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Xingcan Cui (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-8236) Allow to set the parallelism of table queries
Date Mon, 11 Dec 2017 15:12:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Xingcan Cui reassigned FLINK-8236:

    Assignee: Xingcan Cui

> Allow to set the parallelism of table queries
> ---------------------------------------------
>                 Key: FLINK-8236
>                 URL: https://issues.apache.org/jira/browse/FLINK-8236
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>    Affects Versions: 1.4.0
>            Reporter: Timo Walther
>            Assignee: Xingcan Cui
> Right now the parallelism of a table program is determined by the parallelism of the
stream/batch environment. E.g., by default, tumbling window operators use the default parallelism
of the environment. Simple project and select operations have the same parallelism as the
inputs they are applied on.
> While we cannot change forwarding operations because this would change the results when
using retractions, it should be possible to change the parallelism for operators after shuffling
> It should be possible to specify the default parallelism of a table program in the {{TableConfig}}
and/or {{QueryConfig}}. The configuration per query has higher precedence that the configuration
per table environment.

This message was sent by Atlassian JIRA

View raw message