wolfboys commented on issue #1762:
URL:
https://github.com/apache/incubator-streampark/issues/1762#issuecomment-1271792584
to be clear, flinkConf only read the parameters from
`flink.deployment.property`, userConf is all params, Include
`flink.deployment.property` and `user.parameter`, because it is uncertain
whether users will use `flink.deployment.property`. If these parameters are not
exposed, users cannot obtain these parameters in the program.
like this:
```yaml
flink:
deployment:
property:
$key: $value #All parameters that can be set in Flink
....
user.parameter:
kafka.source:
....
```
```
// just from flink.deployment.property:
Configuration flinkConf = new Configuration();
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment(flinkConf);
```
```
// all params, Include flink.deployment.property and user.parameter,
Configuration userConf = new Configuration();
env.getConfig().setGlobalJobParameters(userConf);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
