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:

    https://github.com/apache/flink/pull/5269
  
    @zentol 
    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.


---

Mime
View raw message