diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java
index e6431251ad..8b6f8a109c 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java
@@ -433,7 +433,7 @@ public NodeChannel mapRow(Row row) {
             }
 
             if (usingExtractPeriod) {
-                sqlTemplate.query(getSql("selectNodeChannelControlLastExtractTimeSql"),
+                sqlTemplate.query(getSql("selectNodeChannelControlSql"),
                     new ISqlRowMapper<Object>() {
                         public Object mapRow(Row row) {
                             String channelId = row.getString("channel_id");