使用flink自带的
InputStream inputStream = ParameterTool.class.getClassLoader().getResourceAsStream("application.properties");ParameterTool params = ParameterTool.fromPropertiesFile(inputStream);// 1. 获取String类型参数（如果key不存在，返回null） String input = params.get("input");// 2. 获取String类型参数，如果key不存在，则使用提供的默认值 String output = params.get("output", "/tmp/default-output");// 3. 获取必要参数，如果key不存在，抛出RuntimeException String requiredParam = params.getRequired("db.url");// 4. 获取其他基本类型参数（也支持默认值） int maxParallelism = params.getInt("parallelism", 4); long timeout = params.getLong("timeout.ms", 60000L); float ratio = params.getFloat("ratio", 0.5f); double threshold = params.getDouble("threshold", 0.9); boolean enableFeature = params.getBoolean("feature.enabled", false);// 5. 检查某个参数是否存在 if (params.has("debug.mode")) {// 调试逻辑 }