You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by pluppens <gi...@git.apache.org> on 2018/01/23 12:21:23 UTC

[GitHub] flink issue #5337: [FLINK-8484][flink-kinesis-connector] Ensure a Kinesis co...

Github user pluppens commented on the issue:

    https://github.com/apache/flink/pull/5337
  
    Ok, so you'd prefer to synchronize the state of the retrieve shard against the stored shards by comparing its stream name and shard id, before doing the containsKey() check?


---