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*
