Hi Colleagues,When you are using TextIO() in a Beam (java) app executing in a 
Flink Cluster, do you have to have a copy of the file in every Flink cluster 
node?Also, if you want to read the file from one node (probably remote node) 
only, how would the TextIO.Read.from("....") look like?What are the best 
TextIO() practices in situations like this?Thanks+regards,Amir

Reply via email to