diff --git a/src/main/java/com/salesforce/dataloader/action/AbstractExtractAction.java b/src/main/java/com/salesforce/dataloader/action/AbstractExtractAction.java
index 02e5be7c..84ae2e7f 100644
--- a/src/main/java/com/salesforce/dataloader/action/AbstractExtractAction.java
+++ b/src/main/java/com/salesforce/dataloader/action/AbstractExtractAction.java
@@ -136,6 +136,7 @@ protected List<String> getStatusColumns() throws ExtractException {
 
     @Override
     protected void initOperation() throws DataAccessObjectInitializationException, OperationException {
+        ((SOQLMapper)getController().getMapper()).clearMap();
         if (getController().getConfig().getBoolean(Config.LIMIT_OUTPUT_TO_QUERY_FIELDS)) {
             final List<String> daoColumns = getDaoColumnsFromMapper();
             getDao().setColumnNames(daoColumns);
diff --git a/src/main/java/com/salesforce/dataloader/mapping/SOQLMapper.java b/src/main/java/com/salesforce/dataloader/mapping/SOQLMapper.java
index fd311953..340da63e 100644
--- a/src/main/java/com/salesforce/dataloader/mapping/SOQLMapper.java
+++ b/src/main/java/com/salesforce/dataloader/mapping/SOQLMapper.java
@@ -281,7 +281,6 @@ public Collection<String> getDestColumns() {
     }
     
     public void clearMap() {
-        super.clearMap();
         this.extractionMap.clear();
         this.isInitialized = false;
     }