diff --git a/dbcon/mysql/ha_mcs.cpp b/dbcon/mysql/ha_mcs.cpp
index 6879f4995..598eb51af 100644
--- a/dbcon/mysql/ha_mcs.cpp
+++ b/dbcon/mysql/ha_mcs.cpp
@@ -1205,7 +1205,7 @@ my_bool get_status_and_flush_cache(void *param,
   {
     ha_rows num_rows = cache->num_rows_cached();
     if ((!cache->insert_command && num_rows != 0) ||
-        num_rows == CACHE_FLUSH_THRESHOLD)
+        num_rows >= CACHE_FLUSH_THRESHOLD)
     {
       if ((error= cache->flush_insert_cache()))
       {