Re: Issue while using parallelism.default in flink-conf.yaml file

Hi Mahima, looks like you found the relevant parts of the code already: In JarHandlerUtils.JarHandlerContext#fromRequest, the parallelism value is extracted from the request body or query parameter (the latter is deprecated, though). If none is found, it defaults to 1 and overwrites the configured

Issue while using parallelism.default in flink-conf.yaml file

Hi Team, Please find the query below. Use Case: Using parallelism.default property mentioned in flink-conf.yaml file to enable system-level parallelism in flink configuration. Issue: Even after setting the parallelism.default to 3, on config start the configuration starts with parallelism as 1.