Hi Manas, When running locally, you need `ten_sec_summaries.get_job_client().get_job_execution_result().result()` to wait job finished. However, when you submit to the cluster, you need to delete this code. In my opinion, the current feasible solution is that you prepare two sets of codes for this, although this is annoying. After all, running jobs locally is usually for testing, so it should be acceptable to prepare different codes. In the long run, it should be the flink framework that makes different behaviors according to different environments so that users don’t need to prepare different codes.
Best, Xingbo Manas Kale <manaskal...@gmail.com> 于2020年9月1日周二 下午3:00写道： > Hi, > I am trying to submit a pyFlink job in detached mode using the command: > > ../../flink-1.11.0/bin/flink run -d -py basic_streaming_job.py -j > flink-sql-connector-kafka_2.11-1.11.0.jar > > The jobs are submitted successfully but the command does not return. I > realized that was because I had the following line in > basic_streaming_job.py: > > ten_sec_summaries.get_job_client().get_job_execution_result().result() > > This statement is useful when testing this locally within a minicluster > (using python basic_streaming_job.py) but not needed when the job is > submitted to a cluster. > > So I would like to programmatically detect if the > StreamExecutionEnvironment is a localStreamEnvironment and execute the > above snippet accordingly. How do I do this? > > > Thanks, > Manas >
