无法读取StateBackend Flink的_metadata

Question

我刚刚创建了简单的flink应用程序并启用了检查点。我看到已创建检查点文件，但无法读取它们。文件包含无效字符。如何将这些文件转换为可读格式？ （任何以任何语言或在线方式提供的解决方案对我来说都是不错的）

这里是检查点文件夹结构

checkpoint_folder -> chk-23 -> _metadata
// _metadata file content:
L�$4c464d1a-1e37-47aa-957e-02f587343bbd��
V��������C�Corg.apache.flink.api.java.typeutils.runtime.TupleSerializerSnapshot���
������������������������������������������������������������������������������������������� ������� 

当我打开带有精美文字的时候：

4960 672d 0000 0002 0000 0000 0000 0122
0000 0000 0000 0004 20ba 6b65 f974 81d5
5700 70de 90e4 e791 0000 000c 0000 0080
0000 0001 0000 000c 0000 0000 ffff ffff
ffff ffff 0000 0000 0000 0001 0400 0000
0100 0673 706c 6974 7300 0000 0000 0100
2465 3165 3133 6662 342d 3838 3061 2d34
3063 392d 3965 6539 2d39 3465 3262 6465

• 入口：

public static void main(String[] args) throws Exception {
        final String checkpointPath="file:///to/path/checkpoint_folder";
        // set up the streaming execution environment
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();

        env.setStateBackend(new MemoryStateBackend(checkpointPath, null));
        env.enableCheckpointing(1000);
}

Answer 1

如果要检查或修改检查点文件，建议使用State Processor API。