[GitHub] [incubator-streampark] wolfboys commented on issue #1762: [Feature] Distinguish between Flink parameters and user parameters when starting a Flink job

[GitBox <gi...@apache.org>]

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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org