Hi All,

I'm currently trying python portable runner with Flink. I see there are 3 kinds 
of environment_type available "docker/process/external(loopback)" when submit a 
job. But I didn't find any material explain more.

  1.  For docker, will it create one docker per flink taskmanager?
  2.  For process, does it mean start a python process to run the user code? 
And it seems "command" should be set in the environment config, but what should 
it be?
  3.  For external(loopback), does it mean let flink operator to call an 
external service and by default set to the place where I submit the beam job? 
This looks like all the data will be shift to a single machine and processed 
there.


Thanks,

Mingliang

本邮件及其附件含有小红书公司的保密信息,仅限于发送给以上收件人或群组。禁止任何其他人以任何形式使用(包括但不限于全部或部分地泄露、复制、或散发)本邮件中的信息。如果您错收了本邮件,请您立即电话或邮件通知发件人并删除本邮件!
This communication may contain privileged or other confidential information of 
Red. If you have received it in error, please advise the sender by reply e-mail 
and immediately delete the message and any attachments without copying or 
disclosing the contents. Thank you.

Reply via email to