Hey,
I'm getting this error:
apache_beam.io.filesystem.BeamIOError: Match operation failed with
exceptions {'s3://fiverr-data-science-de
v/beam_poc/beam/wc/input.txt': BeamIOError("exists() operation failed with
exceptions {'s3://fiverr-data-sc
ience-dev/beam_poc/beam/wc/input.txt': ValueError('Must provide one of
client or options')}")} [while runni
ng
'ReadFromText/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/PairWithRestriction0']
with except
ions None

When trying to run a simple pipeline over Flink with an external
environment.

What could be the problem?

Thanks!

Reply via email to