>
> > I came across this thread, which helped to some extent, but not
completely:
> >
> >
https://lists.apache.org/thread.html/a9b6f019b22a65640c272a9497a3c9cc34d68cc2b5c1c9bdebc7ff38%40%3Cuser.beam.apache.org%3E
> >
> >
>
fs
> > system.
> >
> >
> >
> > Should I setup / configure anything at the Job Server?
> >
> >
> >
> > I came across this thread, which helped to some extent, but not
> completely:
> >
> >
> https
>
https://lists.apache.org/thread.html/a9b6f019b22a65640c272a9497a3c9cc34d68cc2b5c1c9bdebc7ff38%40%3Cuser.beam.apache.org%3E
>
>
>
>
> *From: *"Ramanan, Buvana (Nokia - US/Murray Hill)"
>
> *Reply-To: *"user@beam.apache.or
pletely:
>
> https://lists.apache.org/thread.html/a9b6f019b22a65640c272a9497a3c9cc34d68cc2b5c1c9bdebc7ff38%40%3Cuser.beam.apache.org%3E
>
>
>
>
> *From: *"Ramanan, Buvana (Nokia - US/Murray Hill)"
>
> *Reply-To: *"user@beam.apache.org"
> *Date:
ot;
Date: Wednesday, May 27, 2020 at 8:30 PM
To: "user@beam.apache.org"
Subject: Flink Runner with HDFS
Hello,
I am trying to read from, process and write data to HDFS with beam pipelines in
python. Using Flink Runner. Beam version 2.19.0. Flink 1.9.2
My initial code (pasted below my
Hello,
I am trying to read from, process and write data to HDFS with beam pipelines in
python. Using Flink Runner. Beam version 2.19.0. Flink 1.9.2
My initial code (pasted below my sign) to make sure I can read and write, works
fine on Local Runner. However, I get the following error message (p
