大神们,加载属性文件,应该怎么写呢?
ParameterTool
.
https://help.aliyun.com/document_detail/188052.html
在更多flink配置中使用yaml配置,然后从context的globalJobParameters中获取。
pipeline.global-job-parameters: |
'k16:k16',
'k17:k17',
'k18:k18'
Map globalJobParametersMap = env.getConfig().getGlobalJobParameters().toMap();
globalJobParametersMap.get('k16');
赞0
踩0