Please help..
On Fri, 4 Jun 2021, 19:58 Shankar Mane, wrote:
> Team,
>
> I am new to Beam. And running a simple python pipeline on flink as runner.
> Pipelines get Successfully Finished But i am not getting expected output
Team,
I am new to Beam. And running a simple python pipeline on flink as runner.
Pipelines get Successfully Finished But i am not getting expected output at
the end.
#
Here is Pipeline cod
#
*BATCH PIPELINE : *
python3 batch.py \
--input beam-userbase.csv \
--output output/batch \
--runner=SparkRunner \
--spark_submit_uber_jar \
--job_endpoint=localhost:8099 \
--spark_master_