Hi

Flink only have slotSharingGroup API on DataStream class, I can't find any
public API to achieve co-location constraints. Could anyone provide me an
example?

Another question is that if I use slotSharing group, Flink will schedule
two sub tasks to same slot is possible. I think such schedule will always
success because two tasks run in one slot just decrease the resource usage.
Could anyone provide me an example when slotSharing group schedule fail ?

Thanks

-- 
Best regards

Sili Liu

Reply via email to