diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java
index f3180402..81d5b7f2 100755
--- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java
+++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java
@@ -27,10 +27,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.sql.Connection;
-import java.sql.ResultSet;
-import java.sql.ResultSetMetaData;
-import java.sql.Types;
+import java.sql.*;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
@@ -189,6 +186,18 @@ public class CommonRdbmsReader {
             DBUtil.dealWithSessionConfig(conn, readerSliceConfig,
                     this.dataBaseType, basicMsg);
 
+            //deal with drds big data error net_write_timeout
+            if (DataBaseType.DRDS.equals(dataBaseType)){
+                LOG.info("start DRDS  setNetWorkTimeOut...");
+                try {
+                    conn.setNetworkTimeout(Executors.newFixedThreadPool(1), 172800000);
+                    LOG.info("end DRDS  setNetWorkTimeOut...");
+                } catch (SQLException throwables) {
+                    LOG.error("setNetWorkTimeOut error  ["+throwables.getMessage()+"]");
+                    throwables.printStackTrace();
+                }
+            }
+
             int columnNumber = 0;
             ResultSet rs = null;
             try {