fixed BulkShardProcessor.add() blocking while retry is running