...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
public static final ConfigOption<InferMode> TABLE_EXEC_HIVE_INFER_SOURCE_PARALLELISM_MODE = ConfigOptions.key("table.exec.hive.infer-source-parallelism.mode") .enumType(InferMode.class) .defaultValue(InferMode.DYNAMIC) .withDescription( "An option for selecting the hive source parallelism inference mode: 'static' denotes static inference, where flink will determinedecide source parallelism at job creation stage; 'dynamic' represents dynamic inference, which will decide parallelism at job execution stage. In terms of functionality, the static mode is a subset of the dynamic mode. Note: it only works when the value of option 'table.exec.hive.infer-source-parallelism.enabled' is true."); |
...