diff --git a/src/main/java/com/taobao/yugong/extractor/oracle/OracleFullRecordExtractor.java b/src/main/java/com/taobao/yugong/extractor/oracle/OracleFullRecordExtractor.java
index cc0cc72..64f3130 100644
--- a/src/main/java/com/taobao/yugong/extractor/oracle/OracleFullRecordExtractor.java
+++ b/src/main/java/com/taobao/yugong/extractor/oracle/OracleFullRecordExtractor.java
@@ -68,13 +68,14 @@ public void start() {
             this.getMinPkSql = new MessageFormat(MIN_PK_FORMAT).format(new Object[] { primaryKey, schemaName, tableName });
         }
 
+        queue = new LinkedBlockingQueue<>(context.getOnceCrawNum() * 2);
+
         extractorThread = new NamedThreadFactory(this.getClass().getSimpleName() + "-"
                                                  + context.getTableMeta().getFullName()).newThread(new ContinueExtractor(this,
             context,
             queue));
         extractorThread.start();
 
-        queue = new LinkedBlockingQueue<>(context.getOnceCrawNum() * 2);
         tracer.update(context.getTableMeta().getFullName(), ProgressStatus.FULLING);
     }