Hello,
I have used python sdk to write my beam pipelines. I am using celery as a wrapper over direct runner. I want to use flink runner to parallelise my load. As per the documentation, you need to give your job as a jar file for flink runner. Can you point me to any resources where I can use both apache beam python sdk and apache flink? Any samples?
