聊聊flink的checkpoint配置

序 本文主要研究下flink的checkpoint配置html 實例 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); // start a checkpoint every 1000 ms env.enableCheckpointing(1000); // advanc

>>阅读原文<<