flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Elias Levy <fearsome.lucid...@gmail.com>
Subject Tracking deserialization errors
Date Fri, 06 Apr 2018 18:12:14 GMT
I was wondering how are folks tracking deserialization errors.
The AbstractDeserializationSchema interface provides no mechanism for the
deserializer to instantiate a metric counter, and "deserialize" must return
a null instead of raising an exception in case of error if you want your
job to continue functioning during a deserialization error.  But that means
such errors are invisible.


View raw message