Details
Description
Currently NN will pick the (maxStreams-XmitsCount) number of ECtasks at a time for assigning to the respective DN.
//get datanode commands final int maxTransfer = blockManager.getMaxReplicationStreams() - xmitsInProgress;
But right now we increment xmitsInProgress count at DN only for regular replication tasks but not for ECWorker tasks.
So, either we should treat this logic separately for EC or we should consider EC current task handling count form DN.
This jira for discussing more for this case.