Hello all,
My pipeline looks like the following:
(p | "read TXT " >>
beam.io.ReadFromText('gs://path/to/file.txt',skip_header_lines= False)
| "transpose file " >> beam.ParDo(transposeCSVFn(List1,List2)))
The following error is being fired for the read:
INFO:oauth2client.client:Attempting refresh to obtain initial access_token
What might be the issue?
Thanks,
Eila
--
Eila
www.orielresearch.org
https://www.meetu <https://www.meetup.com/Deep-Learning-In-Production/>p.co
<https://www.meetup.com/Deep-Learning-In-Production/>
m/Deep-Learning-In-Production/
<https://www.meetup.com/Deep-Learning-In-Production/>
