[jira] [Updated] (FLINK-27060) [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api
[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27060: - Issue Type: New Feature (was: Improvement) > [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: New Feature > 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)
[jira] [Updated] (FLINK-27060) [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api
[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27060: --- Summary: [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api (was: Extending /jars/:jarid/run API to support setting Flink configs) > [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 >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.10#820010)
