You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ConradJam (Jira)" <ji...@apache.org> on 2022/05/23 09:20:00 UTC
[jira] [Comment Edited] (FLINK-27060) Extending /jars/:jarid/run API to support setting Flink configs
[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540849#comment-17540849 ]
ConradJam edited comment on FLINK-27060 at 5/23/22 9:19 AM:
------------------------------------------------------------
Hi [~martijnvisser] If I can, I can help create flip it, but it seems that I don't have permission at the moment. After creating it, we can add our own ideas 🍻.
The current number has reached FLIP-236, we can create a titled *FLIP-236： Support Job dynamic parameter with* {*}Flink Rest Api{*}{*}{*}
was (Author: JIRAUSER285483):
Hi [~martijnvisser] If I can, I can help create flip it, but it seems that I don't have permission at the moment. After creating it, we can add our own ideas 🍻.
The current number has reached FLIP-236, we can create a titled *FLIP-236： Support Job dynamic parameter with* {*}Flink Rest Api{*}{*}{*}
> Extending /jars/:jarid/run API to support setting Flink configs
> ---------------------------------------------------------------
>
> Key: FLINK-27060
> URL: https://issues.apache.org/jira/browse/FLINK-27060
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / REST
> Reporter: Zhanghao Chen
> Priority: Major
>
> *Background*
> Users want to submit job via Flink REST API instead of Flink CLI which is more heavy-weight in certain scenarios, for example, a lightweight data processing workflow system that has Flink related systems.
> Currently, the /jars/:jarid/run API ([https://nightlies.apache.org/flink/flink-docs-master/docs/ops/rest_api/#jars-jarid-run)] only supports a few selected Flink config options listed in the doc (parallelism、savepoint path and allow non-restored state), which is insufficient for practical use.
> *Proposed Changes*
> Extending the /jars/:jarid/run API with an additional request body parameter "configs", which is a map of flink configuration option-value pairs set by users.
> For backward compatibility, we can retain the existing body parameters like "allowNonRestoredState", and when there's conflicting configurations, let the values set explicitly with existing body parameters take higher precedence over the values set by configs.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)