Hi all, Was there any change in how sub-tasks get allocated to TMs, from Flink 1.9 to 1.10?
Specifically for consecutively numbered sub-tasks (e.g. 0, 1, 2) did it become more or less likely that they’d be allocated to the same Task Manager? Asking because a workflow that ran fine in 1.9 now has a “hot” TM that’s having trouble keeping up with a Kafka topic. The most promising explanation is that now there are three sub-tasks on the same TM that are reading from that topic, versus previously they’d be scattered across multiple TMs. But I don’t see significant changes in this area post 1.8 Thanks, — Ken -------------------------- Ken Krugler http://www.scaleunlimited.com custom big data solutions & training Hadoop, Cascading, Cassandra & Solr
