Re: UNIMPLEMENTED method: org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool/StartWorker

2022-09-21 Thread Lydian
Yes, the logs is on TaskManager. The command line options is: ``` --streaming --runner=portableRunner --environment_type=PROCESS --environment_config={"command": "/opt/apache/beam/boot"} ``` Note that I actually copied both python and java in the same docker image for both job and task manager in

Re: UNIMPLEMENTED method: org.apache.beam.model.fn_execution.v1.BeamFnExternalWorkerPool/StartWorker

2022-09-21 Thread Jan Lukavský
Hi Lydian, I'm not sure about this one. Can you please clarify - the logs are logs of TaskManager, right? Can you please share the command line options you pass to the Pipeline? I'm not sure why the SDK harness would need the job server, that seems strange. Can you let the python x-lang tran