reduce copy_queue_size to 1000

Author: wangzw

gpdbwriter/doc/gpdbwriter.md

@@ -74,7 +74,7 @@ GpdbWriter通过 DataX 框架获取 Reader 生成的协议数据，根据你配
                         "username": "xx",
                         "password": "xx",
                         "segment_reject_limit": 0,
-                        "copy_queue_size": 100000,
+                        "copy_queue_size": 1000,
                         "num_copy_processor": 4,
                         "num_copy_writer": 1,
                         "column": [
@@ -143,7 +143,7 @@ GpdbWriter通过 DataX 框架获取 Reader 生成的协议数据，根据你配
 * **copy\_queue\_size**
   * 描述： 线程异步队列大小，增大此参数增加内存消耗，提升性能
   * 必选： 否
-  * 默认值：100000
+  * 默认值：1000
 
 * **num\_copy\_processor**
   * 描述： 用于进行格式化数据的线程数

gpdbwriter/src/main/java/cn/hashdata/datax/plugin/writer/gpdbwriter/CopyWriterTask.java

@@ -91,8 +91,8 @@ public void startWrite(RecordReceiver recordReceiver, Configuration writerSliceC
 			TaskPluginCollector taskPluginCollector) {
 		this.writerSliceConfig = writerSliceConfig;
 		int segment_reject_limit = writerSliceConfig.getInt("segment_reject_limit", 0);
-		this.queueSize = writerSliceConfig.getInt("copy_queue_size", 100000);
-		this.queueSize = this.queueSize < 1000 ? 1000 : this.queueSize;
+		this.queueSize = writerSliceConfig.getInt("copy_queue_size", 1000);
+		this.queueSize = this.queueSize < 10 ? 10 : this.queueSize;
 		this.numProcessor = writerSliceConfig.getInt("num_copy_processor", 4);
 		this.numProcessor = this.numProcessor < 1 ? 1 : this.numProcessor;
 		this.numWriter = writerSliceConfig.getInt("num_copy_writer", 1);