Re: [Question] Python Batch Pipeline On Flink - No Output

2021-06-18 Thread Shankar Mane
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

[Question] Python Batch Pipeline On Flink - No Output

2021-06-04 Thread Shankar Mane
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

[Question] Python Batch Pipeline Errors

2021-06-03 Thread Shankar Mane
# *BATCH PIPELINE : * python3 batch.py \ --input beam-userbase.csv \ --output output/batch \ --runner=SparkRunner \ --spark_submit_uber_jar \ --job_endpoint=localhost:8099 \ --spark_master_