1. what i grasp there are 4 part, and the data flow and call step is describe as below, is it right?
user python code -> beam-runners-flink-1.8-job-server -> SDK harness -> flink cluster. 1. What's every part's responsiblity for the 4 part?
