Hi Jiawei, Could you try Flink latest release 1.11? 1.8 will probably not get bugfix releases. I will cc Ying Xu who might have a better idea about the DinamoDB source.
Best, Andrey On Thu, Sep 10, 2020 at 3:10 PM Jiawei Wu <wujiawei5837...@gmail.com> wrote: > Hi, > > I'm using AWS kinesis analytics application with Flink 1.8. I am using > the FlinkDynamoDBStreamsConsumer to consume DynamoDB stream records. But > recently I found my internal state is wrong. > > After I printed some logs I found some DynamoDB stream record are skipped > and not consumed by Flink. May I know if someone encountered the same issue > before? Or is it a known issue in Flink 1.8? > > Thanks, > Jiawei >
