我已经研究过这个解决方案，所以一个是您可以在link cluster的flink-conf.yaml中更改checkpoint.state.dir路径，另一个是使用flinkpipelineoptions-

@Description(
                "Sets the state backend factory to use in streaming mode. "
                        + "Defaults to the flink cluster's state.backend configuration.")
        Class<? extends FlinkStateBackendFactory> getStateBackendFactory();
        void setStateBackendFactory(Class<? extends FlinkStateBackendFactory> stateBackendFactory);

通过设置setstatebackendfactory（我已经使用自定义类）

static class  bakend implements FlinkStateBackendFactory{

        @Override
        public StateBackend createStateBackend(FlinkPipelineOptions options) {
            return new FsStateBackend("file:///Users/myPc/word-count-beam/src/checkpoint/");

        }
    }

这将创建一个checkpointdir。您还需要设置checkpointinginterval的值，以便启用检查点。