Hi, that is correct. If you are using custom serializers you should double check their correctness, maybe using our test base for type serializers. Another reason could be that you modified the job in a way that silently changed the schema somehow. Concurrent use of serializers across different threads can also cause problems like this and I think there was a bug in 1.4 around this topic. I suggest that you also update to a newer version, at least the latest bugfix release.
Best, Stefan > Am 21.09.2018 um 10:26 schrieb vino yang <yanghua1...@gmail.com>: > > Hi Qingxiang, > > Several days ago, Stefan described the causes of this anomaly in a problem > similar to this: > Typically, these problems have been observed when something was wrong with a > serializer or a stateful serializer was used from multiple threads. > > Thanks, vino. > > Marvin777 <xymaqingxiang...@gmail.com <mailto:xymaqingxiang...@gmail.com>> > 于2018年9月21日周五 下午3:20写道： > Hi all, > > When Flink(1.4.2) job starts, it could find checkpoint files at HDFS, but > exception occurs during deserializing: > > <image.png> > > Do you have any insight on this? > > Thanks, > Qingxiang Ma
