flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzulitai <...@git.apache.org>
Subject [GitHub] flink issue #5269: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip...
Date Wed, 31 Jan 2018 12:40:09 GMT
Github user tzulitai commented on the issue:

    The contract is that if `KinesisDeserializationSchema.deserialize()` returns `null`, that
record will be skipped. I agree it makes sense to have a add a warning log if this happens.


View raw message