研究flinkcheckpoint1

    /*//===========Checkpoint参数设置====
    //===========类型1:必须参数=============
    //设置Checkpoint的时间间隔为1000ms做一次Checkpoint/其实就是每隔1000ms发一次Barrier!
    env.enableCheckpointing(1000);
    //设置State状态存储介质
    if(SystemUtils.IS_OS_WINDOWS){
        env.setStateBackend(new FsStateBackend("file:///D:\\data\\ckp"));
    }else{
        env.setStateBackend(new FsStateBackend("hdfs://node1:8020/flink-checkpoint/checkpoint"));
    }