Hi, Felipe Flink does not support run tasks on specified TM. You can use slotSharingGroup to control Tasks not in same Slot, but cannot specified which TM.
Can you please give the reason for specifying TM? Best Weihua Hu > 2020年5月28日 21:37，Felipe Gutierrez <felipe.o.gutier...@gmail.com> 写道： > > For instance, if I have the following DAG with the respect parallelism > in parenthesis (I hope the dag appears real afterall): > > source01 -> map01(4) -> flatmap01(4) \ > > |-> keyBy -> reducer(8) > source02 -> map02(4) -> flatmap02(4) / > > And I have 4 TMs in 4 machines with 4 cores each. I would like to > place source01 and map01 and flatmap01 in TM-01. source02 and map02 > and flatmap02 in TM-02. I am using "disableChaning()" in the faltMap > operator to measure it. And reducer1-to-4 in TM-03 and reducer5-to-8 > in TM-04. > > I am using the methods "setParallelism()" and "slotSharingGroup()" to > define it but both source01 and source02 are placed in TM-01 and map01 > is split into 2 TMs. The same with map02. > > Thanks, > Felipe > -- > -- Felipe Gutierrez > -- skype: felipe.o.gutierrez > -- https://felipeogutierrez.blogspot.com
