You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Alexey Romanenko (Jira)" <ji...@apache.org> on 2020/08/14 15:52:00 UTC

[jira] [Assigned] (BEAM-10706) DynamoDBIO fail to write to the same key in short consecution

     [ https://issues.apache.org/jira/browse/BEAM-10706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Alexey Romanenko reassigned BEAM-10706:
---------------------------------------

    Assignee: Dennis Yung

> DynamoDBIO fail to write to the same key in short consecution
> -------------------------------------------------------------
>
>                 Key: BEAM-10706
>                 URL: https://issues.apache.org/jira/browse/BEAM-10706
>             Project: Beam
>          Issue Type: Bug
>          Components: io-java-aws
>    Affects Versions: 2.23.0
>            Reporter: Dennis Yung
>            Assignee: Dennis Yung
>            Priority: P2
>
> Internally, DynamoDBIO.Write uses the batchWriteItem method from the AWS SDK to sink items. However, there is a limitation in the AWS SDK that a call to batchWriteItem cannot contain duplicate keys.
> Currently DynamoDBIO.Write performs no key deduplication before flushing a batch, which could cause ValidationException: Provided list of item keys contains duplicates, if consecutive updates to a single key is within the batch size (currently hardcoded to be 25). 
> To fix this bug, the batch of write requests need to be deduplicated before being sent to batchRequest.addRequestItemsEntry



--
This message was sent by Atlassian Jira
(v8.3.4#803005)