Hi,
I do not use custom serializers, and my job contains only source and
sink(BucketingSink). What causes this phenomenon in general?
I suggest that you also update to a newer version, at least the latest
> bugfix release
Which version does this sentence refer to? And could you please help l
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
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 于2018年9月21日周五 下午3:20
