Hi, What would happen when new worker joins after the synchronization barrier ?
As per code -> performTaskAssignment function of IncrementalAssignor -> Boolean canRevoke is false when it is called during the 2nd rebalance. Hence revocation is skipped and only assignment is done. This would lead to imbalance in #tasks/#connectors. How is this case handled ? Thanks, Ahmed