Hi,
I am trying to do something like below :
PCollection<String> pc1=<some collection>;
pc1.apply(TextIO.Write.to("gs://BucketA/fileA.txt"))
PCollection<String> pc2=TextIO.Read.from("gs://BucketA/fileA.txt")
When I execute the above in a pipeline, I get an error when I try to read
from the GS bucket-
java.lang.IllegalStateException: Unable to find any files matching
StaticValueProvider{value=gs://beamoutput/test105A.txt}
Is there a mechanism to ensure that the read above does not happen before
the write ?
Thanks,
Seshadri
