Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10358

Flink kinesis connector could throw NPE during getRecords() call

    XMLWordPrintableJSON

    Details

      Description

      When extending the flink kinesis connector to consume from a dynamodb stream, it was found NPE could be thrown at here . 

      This is because the getRecords API in dynamodb streams does not return the millisBehindLatest field and has it set to null.  Null check is probably needed here.

      See FLINK-4582 for the context of building dynamodb streams connector on top of the Kinesis connector. 

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                yxu-lyft Ying Xu
                Reporter:
                yxu-apache Ying Xu
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: