flink程序常用环境设置

public class FlinkUtils {public static StreamExecutionEnvironment getEnv(){StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();//设置全局并行度，如果不设置，则默认为配置文件中配置的平行度。优先级：代码>配置文件// env.setParallelism(1);        //设置程序环境的时间类型//env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime);//开启checkpoint,必须开启env.enableCheckpointing(30*1000, CheckpointingMode.EXACTLY_ONCE);//确保检查点之间至少有1500ms的间隔env.getCheckpointConfig().setMinPauseBetweenCheckpoints(1500);//检查点必须在1min内完成env.getCheckpointConfig().setCheckpointTimeout(60000);//同一时间值允许进行一个检查点env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);//当任务失败是checkpoint被保存，手动退出时也保存env.getCheckpointConfig().enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);//设置重启策略,30s钟重启一次，最多重启5次env.setRestartStrategy(RestartStrategies.fixedDelayRestart(5, Time.of(30, TimeUnit.SECONDS)));return env;}
}