[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-27060. ------------------------------------ Fix Version/s: 1.17.0 Resolution: Fixed > [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api > ------------------------------------------------------------ > > Key: FLINK-27060 > URL: https://issues.apache.org/jira/browse/FLINK-27060 > Project: Flink > Issue Type: Improvement > Components: Runtime / REST > Reporter: Zhanghao Chen > Assignee: ConradJam > Priority: Major > Fix For: 1.17.0 > > > *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.10#820010)