flink-issues mailing list archives

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

             Summary: 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
            Reporter: Timo Walther

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