I’m not sure that I get it correctly. What do you mean by “worker pool” in your case?
— Alexey > On 8 Oct 2022, at 03:24, Xiao Ma <xia...@geotab.com> wrote: > > Hello, > > I would like to run a pipeline with Java as the main language and python > transformation embedded. The beam pipeline is running on the flink cluster. > Currently, I can run it with a taskmanager + java worker pool and a python > worker pool. Could I ask if there is a way to run the java code on the task > manager directly and keep the python worker pool? > > Current: taskmanager + java worker pool + python worker pool > Desired: taskmanager + python worker pool > > Thank you very much. > > Mark Ma >
