diff --git a/deps/oblib/src/rpc/obmysql/ob_sql_nio.cpp b/deps/oblib/src/rpc/obmysql/ob_sql_nio.cpp
index 828b09db4a..4f087dc126 100644
--- a/deps/oblib/src/rpc/obmysql/ob_sql_nio.cpp
+++ b/deps/oblib/src/rpc/obmysql/ob_sql_nio.cpp
@@ -317,7 +317,7 @@ private:
         LOG_WARN("write data error", K(errno));
       }
     }
-    if (OB_SUCCESS == ret || EAGAIN == ret) {
+    if (OB_SUCCESS == ret || OB_EAGAIN == ret) {
       consume_bytes = pos;
       ret = OB_SUCCESS;
     }