Assume that I have a cluster of machines with different powers (i.e. different CPU, Memory, etc.). Is there any way to determine the location of a specific operator (or maybe task) to run? Is it possible to change the default running location of an operator?
I read about "Task chaining and resource groups". However, I think it is not solve my problem.
Is there any specific configuration in Flink? if no, What part of code may relates to this assumption?
someStream.filter(...).slotSharingGroup("name");
as you might have seen at ci.apache.org/projects/flink/flink-docs-stable/dev/stream/…. And it is not a "must do" for the specific group. It only tries if it can. Because it follows the approach to deploy your job whenever is possible....