diff --git a/src/logservice/libobcdc/src/ob_log_systable_helper.cpp b/src/logservice/libobcdc/src/ob_log_systable_helper.cpp
index bd9814c1e3..282720c003 100644
--- a/src/logservice/libobcdc/src/ob_log_systable_helper.cpp
+++ b/src/logservice/libobcdc/src/ob_log_systable_helper.cpp
@@ -1438,7 +1438,7 @@ int ObLogSysTableHelper::do_query_(MySQLQueryBase &query)
       ret = OB_SUCCESS;
     }
 
-    if ((OB_SUCC(ret)) && !done) {
+    if (!done) {
       ret = OB_NEED_RETRY;
     }
   }