beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Carl McGraw (JIRA)" <>
Subject [jira] [Commented] (BEAM-2660) Set PubsubIO batch size using builder
Date Sat, 22 Jul 2017 23:26:00 GMT


Carl McGraw commented on BEAM-2660:

I already have a fork with BoundedPubsubWriter working with a configurable batch size. I need
to update to include UnboundedPubsubSink as well.

> Set PubsubIO batch size using builder
> -------------------------------------
>                 Key: BEAM-2660
>                 URL:
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-gcp
>            Reporter: Carl McGraw
>            Assignee: Stephen Sisk
>              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

View raw message