Не могу прочитать _metadata для StateBackend Flink - PullRequest
Новая
       7

Не могу прочитать _metadata для StateBackend Flink

1 голос
/ 26 марта 2020

Я только что создал простое приложение 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);
}

1 Ответ

1 голос
/ 29 марта 2020

Если вы хотите либо проверять, либо изменять файлы контрольных точек, рекомендуемый способ сделать это - API обработчика состояний .

ReadRidesAndFaresSnapshot - это простой пример, который может читать контрольные точки, написанные RidesAndFaresSolution .

...