hi,aven.wu 可以使用 ParameterTool 获取到传入的参数,然后通过 env.getConfig().setGlobalJobParameters(parameterTool);
在算子中可以在 open 方法里面通过 getRuntimeContext().getExecutionConfig().getGlobalJobParameters(); 获取到配置 aven.wu <[email protected]> 于2020年3月11日周三 下午3:42写道: > Hi,大家好! > 遇到一个问题,在使用flink run > 提交任务时命令行参数也是就那些被main方法接收的那些,不知道如何在taskManager获取到。导致必须从外部系统(hdfs,文件)来读取例如ES,mysql等连接配置。Flink是否有这种广播命令行参数的能力,如果没有是否会考虑加入这个特性。 > > Best > Aven > >
