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);