创建Flink流式环境时间语义设置为事件时间并行度为1开启检查点检查点超时时间为1分钟
可以通过以下代码创建Flink流式环境:
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.TimeCharacteristic;
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
env.setParallelism(1);
env.enableCheckpointing(60000);
这将创建一个Flink流式环境,将时间语义设置为事件时间,将并行度设置为1,并启用检查点。检查点超时时间设置为1分钟,即60000毫秒。
原文地址: http://www.cveoy.top/t/topic/hoCJ 著作权归作者所有。请勿转载和采集!