想知道state写到checkpoint文件没有

Mon, 20 Jul 2020 21:02:59 -0700 

  请问怎么反编译checkpoint文件啊，我想知道state写到checkpoint文件没有




         _default_        
OPERATOR_STATE_DISTRIBUTION_MODE SPLIT_DISTRIBUTE    
VALUE_SERIALIZER    
Gorg.apache.flink.api.common.typeutils.ParameterlessTypeSerializerConfigzS酿 
     脂?sr -org.apache.flink.runtime.state.JavaSerializerFSX韦4
?  xr 
Borg.apache.flink.api.common.typeutils.base.TypeSerializerSingletony﹪.wE 
 xr 4org.apache.flink.api.common.typeutils.TypeSerializer      
   xp    -org.apache.flink.runtime.state.JavaSerializer 
topic-partition-offset-states        
OPERATOR_STATE_DISTRIBUTION_MODE UNION    VALUE_SERIALIZER  
  
Iorg.apache.flink.api.java.typeutils.runtime.TupleSerializerConfigSnapshotzS酿 
    矛?sr 
;org.apache.flink.api.java.typeutils.runtime.TupleSerializer    
     xr 
?org.apache.flink.api.java.typeutils.runtime.TupleSerializerBase    
    I arityI length[ fieldSerializerst 
7[Lorg/apache/flink/api/common/typeutils/TypeSerializer;L 
tupleClasst Ljava/lang/Class;xr 
4org.apache.flink.api.common.typeutils.TypeSerializer      
   xp   r 
7[Lorg.apache.flink.api.common.typeutils.TypeSerializer;9?Ч麡  xp  
 sr 
?org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer    
    L defaultSerializerClassest Ljava/util/LinkedHashMap;L 
defaultSerializersq ~  L kryoRegistrationsq ~         L registeredTypest 
Ljava/util/LinkedHashSet;L $registeredTypesWithSerializerClassesq ~        L 
registeredTypesWithSerializersq ~    L typeq ~ xq ~ sr 
java.util.LinkedHashMap4繬\l利 Z accessOrderxr java.util.HashMap诹?`? 
F 
loadFactorI     thresholdxp?@      w       
x sq ~ ?@     w       x sq ~ ?@  
   w      t 
Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionsr 
<org.apache.flink.api.java.typeutils.runtime.KryoRegistrationJ?坣厏o L 
registeredClassq ~ L serializableSerializerInstancet 
DLorg/apache/flink/api/common/ExecutionConfig$SerializableSerializer;L 
serializerClassq ~ L serializerDefinitionTypet 
WLorg/apache/flink/api/java/typeutils/runtime/KryoRegistration$SerializerDefinitionType;xpvr
 Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition
[/剀X5 I&nbsp;
cachedHashI     partitionL topict Ljava/lang/String;xppp~r 
Uorg.apache.flink.api.java.typeutils.runtime.KryoRegistration$SerializerDefinitionType&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; xr java.lang.Enum&nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; xpt UNSPECIFIEDt )org.apache.avro.generic.GenericData$Arraysq ~ vr 
Uorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroRegisteredClass&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;xppvr 
Yorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroKryoSerializerClass&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;xp~q ~ t CLASSx pppq ~ sr 
9org.apache.flink.api.common.typeutils.base.LongSerializer&nbsp; &nbsp; &nbsp; 
&nbsp;&nbsp; xr 
Borg.apache.flink.api.common.typeutils.base.TypeSerializerSingletony﹪.wE&nbsp;
 xq ~ vr &amp;org.apache.flink.api.java.tuple.Tuple2&nbsp; &nbsp; &nbsp; 
&nbsp; L f0t Ljava/lang/Object;L f1q ~ )xr 
%org.apache.flink.api.java.tuple.Tuple&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
xp&nbsp; &nbsp;&nbsp; &nbsp;&nbsp; &nbsp; &nbsp; ;&nbsp; ? ? )&nbsp; 
&nbsp;&nbsp; 3 sr 
?org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer&nbsp; &nbsp; 
&nbsp; &nbsp; L defaultSerializerClassest Ljava/util/LinkedHashMap;L 
defaultSerializersq ~ L kryoRegistrationsq ~ L registeredTypest 
Ljava/util/LinkedHashSet;L $registeredTypesWithSerializerClassesq ~ L 
registeredTypesWithSerializersq ~ L typet Ljava/lang/Class;xr 
4org.apache.flink.api.common.typeutils.TypeSerializer&nbsp; &nbsp; &nbsp; 
&nbsp;&nbsp; xpsr java.util.LinkedHashMap4繬\l利 Z accessOrderxr 
java.util.HashMap诹?`? F&nbsp;
loadFactorI     thresholdxp?@&nbsp; &nbsp; &nbsp; w&nbsp; &nbsp;&nbsp; &nbsp; 
x sq ~ ?@&nbsp; &nbsp; &nbsp;w&nbsp; &nbsp;&nbsp; &nbsp; x sq ~ ?@&nbsp; 
&nbsp; &nbsp;w&nbsp; &nbsp;&nbsp; &nbsp;t 
Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionsr 
<org.apache.flink.api.java.typeutils.runtime.KryoRegistrationJ?坣厏o L 
registeredClassq ~ L serializableSerializerInstancet 
DLorg/apache/flink/api/common/ExecutionConfig$SerializableSerializer;L 
serializerClassq ~ L serializerDefinitionTypet 
WLorg/apache/flink/api/java/typeutils/runtime/KryoRegistration$SerializerDefinitionType;xpvr
 Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition
[/剀X5 I&nbsp;
cachedHashI     partitionL topict Ljava/lang/String;xppp~r 
Uorg.apache.flink.api.java.typeutils.runtime.KryoRegistration$SerializerDefinitionType&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; xr java.lang.Enum&nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; xpt UNSPECIFIEDt )org.apache.avro.generic.GenericData$Arraysq ~ vr 
Uorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroRegisteredClass&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;xppvr 
Yorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroKryoSerializerClass&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;xp~q ~ t CLASSx pppq ~ &nbsp; &nbsp; 
\org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer$KryoSerializerConfigSnapshotzS酿&nbsp;
 &nbsp;&nbsp; 3 sr 
?org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer&nbsp; &nbsp; 
&nbsp; &nbsp; L defaultSerializerClassest Ljava/util/LinkedHashMap;L 
defaultSerializersq ~ L kryoRegistrationsq ~ L registeredTypest 
Ljava/util/LinkedHashSet;L $registeredTypesWithSerializerClassesq ~ L 
registeredTypesWithSerializersq ~ L typet Ljava/lang/Class;xr 
4org.apache.flink.api.common.typeutils.TypeSerializer&nbsp; &nbsp; &nbsp; 
&nbsp;&nbsp; xpsr java.util.LinkedHashMap4繬\l利 Z accessOrderxr 
java.util.HashMap诹?`? F&nbsp;
loadFactorI     thresholdxp?@&nbsp; &nbsp; &nbsp; w&nbsp; &nbsp;&nbsp; &nbsp; 
x sq ~ ?@&nbsp; &nbsp; &nbsp;w&nbsp; &nbsp;&nbsp; &nbsp; x sq ~ ?@&nbsp; 
&nbsp; &nbsp;w&nbsp; &nbsp;&nbsp; &nbsp;t 
Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionsr 
<org.apache.flink.api.java.typeutils.runtime.KryoRegistrationJ?坣厏o L 
registeredClassq ~ L serializableSerializerInstancet 
DLorg/apache/flink/api/common/ExecutionConfig$SerializableSerializer;L 
serializerClassq ~ L serializerDefinitionTypet 
WLorg/apache/flink/api/java/typeutils/runtime/KryoRegistration$SerializerDefinitionType;xpvr
 Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition
[/剀X5 I&nbsp;
cach发送edHashI   partitionL topict Ljava/lang/String;xppp~r 
Uorg.apache.flink.api.java.typeutils.runtime.KryoRegistration$SerializerDefinitionType&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; xr java.lang.Enum&nbsp; &nbsp; &nbsp; &nbsp; 
&nbsp; xpt UNSPECIFIEDt )org.apache.avro.generic.GenericData$Arraysq ~ vr 
Uorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroRegisteredClass&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;xppvr 
Yorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroKryoSerializerClass&nbsp;
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;xp~q ~ t CLASSx pppq ~ &nbsp; &nbsp; 
Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition&nbsp;
 &nbsp; 
Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition 
Iorg.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition&nbsp;
 &nbsp; &nbsp;)org.apache.avro.generic.GenericData$Array 
Uorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroRegisteredClass&nbsp;
 &nbsp; 
Yorg.apache.flink.api.java.typeutils.runtime.kryo.Serializers$DummyAvroKryoSerializerClass&nbsp;
 &nbsp;&nbsp; &nbsp;猬?sr 
9org.apache.flink.api.common.typeutils.base.LongSerializer&nbsp; &nbsp; &nbsp; 
&nbsp;&nbsp; xr 
Borg.apache.flink.api.common.typeutils.base.TypeSerializerSingletony﹪.wE&nbsp;
 xr 4org.apache.flink.api.common.typeutils.TypeSerializer&nbsp; &nbsp; &nbsp; 
&nbsp;&nbsp; xp&nbsp; &nbsp; 
Porg.apache.flink.api.common.typeutils.base.LongSerializer$LongSerializerSnapshot&nbsp;
 &nbsp; 9org.apache.flink.api.common.typeutils.base.LongSerializer vr 
&amp;org.apache.flink.api.java.tuple.Tuple2&nbsp; &nbsp; &nbsp; &nbsp; L 
f0t Ljava/lang/Object;L f1q ~ xr 
%org.apache.flink.api.java.tuple.Tuple&nbsp; &nbsp; &nbsp; &nbsp;&nbsp; 
xp&nbsp;&nbsp;

回复