recovery.cc | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/recovery.cc b/recovery.cc
index f16f503..c944afd 100644
--- a/recovery.cc
+++ b/recovery.cc
@@ -569,7 +569,17 @@ int Recovery_module::wait_for_applier_module_recovery()
                       " transactions received during recovery.");
           DBUG_RETURN(1);
         }
-        /* purecov: end */	
+        /* purecov: end */
+
+		transactions_applied_during_recovery= applier_module
+		  ->get_pipeline_stats_member_collector_transactions_applied_during_recovery();
+		queue_size = applier_module->get_message_queue_size();
+		
+		if (error != 0 && queue_initial_size < transactions_applied_during_recovery
+			&& queue_size <= DEFAULT_FLOW_CONTROL_THRESHOLD)
+		{
+		  error = 0;
+		}		
       }
       applier_monitoring= false;
     }