diff --git a/src/ag_gen/ag_gen.cpp b/src/ag_gen/ag_gen.cpp
index ee75805..90206a6 100755
--- a/src/ag_gen/ag_gen.cpp
+++ b/src/ag_gen/ag_gen.cpp
@@ -384,7 +384,7 @@ AGGenInstance &AGGen::generate(bool batch_process, int batch_size, int numThrd,
 
         //Create Communicators
         boost::mpi::communicator tcomm = world.split(world.rank() > 0 && world.rank() <= alloc);
-        boost::mpi::communicator ttwo_comm = world.split(world.rank() == send_check(world, alloc) && world.rank() <= (2*two_alloc));
+        boost::mpi::communicator ttwo_comm = world.split(world.rank() >= send_check(world, alloc) && world.rank() <= (2*two_alloc));
 
     	while (!localFrontier.empty() || !unex_empty() || world.rank() > 0){//while starts
 
diff --git a/src/mpi/tasks.cpp b/src/mpi/tasks.cpp
index 3a98e37..2f61881 100644
--- a/src/mpi/tasks.cpp
+++ b/src/mpi/tasks.cpp
@@ -156,7 +156,8 @@ void task_two(AGGenInstance &instance, int alloc, int two_alloc, boost::mpi::com
     std::deque<NetworkState> &localFrontier, double mem_threshold, boost::mpi::communicator &ttwo_comm,\
     std::vector<std::string> ex_groups, std::unordered_map<size_t, int> &hash_map){   
 
-    std::cout << "Process rank " << world.rank() << " with " << two_alloc << " node(s) allocated has started Task 2." << std::endl;
+    std::cout << "Process rank " << world.rank() << " with " << two_alloc <<\
+     " node(s) allocated has started Task 2 with local communicator rank of " << ttwo_comm.rank() << std::endl;
 
     NetworkState current_state;
     std::vector<std::tuple<Exploit, AssetGroup>> appl_exploits;