Hello, is there a way to pass the requester pay project using
textio.Read("gs://my-bucket")?

Apache beam is returning this error when i try accessing a bucket with this
property active:

4: SDF.SplitAndSizeRestrictions[textio.readFn] UID:4 Out:[2] 3:
> PCollection[ne5_splitnsized] Out:[2] 2:
> DataSink[S[ee5_splitnsize_i0@localhost:43511]]
> Coder:W;cwv_ne5_splitnsized<KV;ce5kv_ele_rest_size_lp<KV;ce5kv_ele_rest_lp<LP;c3_lp<R[fileio.Readab
> leFile]>,KV;c7<offsetrange.Restriction[offsetrange.Restriction;c4];c5,bool;c6>>,double;ce5size>>!GWC
> caused by: DoFn[UID:10, PID:e3, Name:
> github.com/apache/beam/sdks/v2/go/pkg/beam/io/fileio.matchFn] failed:
> googleapi: Error 400: Bucket is a requester pays bucket but no user project
> provided., required source=/go/pkg/mod/github.com/apache/beam/sdks/v2@v2.
> 54.0/go/pkg/beam/core/runtime/harness/harness.go:492
> time=2024-03-25T11:58:07.084Z
> worker.ID=job-001[go-job-1-1711367886775655910]_go worker.endpoint
> =localhost:43511


Thanks for your help

*Leonardo Cesar Borges
<https://www.linkedin.com/in/leonardo-cesar-borges-15419615/>*
leonardo.bor...@neoway.com.br

*Florianópolis - SC*
Rua Patricio Farias, nº 131, 3º andar - Itacorubi
<https://maps.google.com/?q=Rua+Patricio+Farias,+n%C2%BA+131,+3%C2%BA+andar+-+Itacorubi+CEP:+88034-132&entry=gmail&source=g>
CEP: 88034-132
<https://maps.google.com/?q=Rua+Patricio+Farias,+n%C2%BA+131,+3%C2%BA+andar+-+Itacorubi+CEP:+88034-132&entry=gmail&source=g>
www.neoway.com.br




   - <http://www.linkedin.com/company/neoway>
   - <https://twitter.com/neoway_nw>
   - <http://www.facebook.com/Neoway-165329300179538/>

Reply via email to