Flink 本地任务添加配置参数

作者：运维做开发 | 2024-07-03 10:20:13

踩

Flink 本地任务添加配置参数

配置一个Configuration，然后通过StreamExecutionEnvironment.getExecutionEnvironment(configuration)传入。
例如：

		Configuration configuration = new Configuration();
        configuration.set(RestartStrategyOptions.RESTART_STRATEGY,"fixed-delay");
        configuration.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS, 3);
        configuration.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY, Duration.ofMinutes(1));
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(configuration);
1
2
3
4
5

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/运维做开发/article/detail/782794