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
