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

Posted to commits@beam.apache.org by "Stephen Sisk (JIRA)" <ji...@apache.org> on 2017/10/06 16:52:00 UTC

[jira] [Assigned] (BEAM-2660) Set PubsubIO batch size using builder

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

Stephen Sisk reassigned BEAM-2660:
----------------------------------

    Assignee: Chamikara Jayalath  (was: Stephen Sisk)

> Set PubsubIO batch size using builder
> -------------------------------------
>
>                 Key: BEAM-2660
>                 URL: https://issues.apache.org/jira/browse/BEAM-2660
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-gcp
>            Reporter: Carl McGraw
>            Assignee: Chamikara Jayalath
>              Labels: gcp, java, pubsub, sdk
>
> PubsubIO doesn't allow users to set the publish batch size. Instead the value is hard coded in both the BoundedPubsubWriter and the UnboundedPubsubSink. 
> google's pub/sub is bound to a maximum of 10mb per request size. My company has run into problems with events that are individually smaller than 1mb, but when batched in the 100 or 2000 default batch sizes causes pubsub to fail to send the event.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)