admin管理员组

文章数量:1530875

1，我们先看一下最简单的代码，消费kafka的数据然后state存储，通过checkpoint保存到hdfs

package application;

import appOperator.stateMap;
import org.apache.flink.apimon.restartstrategy.RestartStrategies;
import org.apache.flink.apimon.serialization.SimpleStringSchema;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.contrib.streaming.state.RocksDBStateBackend;
import org.apache.flink.streaming.api.CheckpointingMode;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.CheckpointConfig;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer010;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.Properties;

public class CheckPointState_demo {
    private static Logger logger &#

本文标签： 状态FlinkCheckPoint

版权声明：本文标题：Flink通过checkpoint实现状态恢复 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://m.elefans.com/dongtai/1725750127a1040675.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。