Configuration

Depending on the requirements of a table program, it might be necessary to adjust certain parameters for optimization. For example, unbounded streaming programs may need to ensure that the required state size is capped (see streaming concepts).

In every table environment, the offers options for configuring the current session.

For common or important configuration options, the TableConfig provides getters and setters methods with detailed inline documentation.

For more advanced configuration, users can directly access the underlying key-value map. The following sections list all available options that can be used to adjust Flink Table & SQL API programs.

Java

Scala

Python

SQL CLI

The following options can be used to adjust the behavior of the query optimizer to get a better execution plan.

The following options can be used to adjust the behavior of the table planner.