diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IStatisticService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IStatisticService.java
index e4367fa00d..a59ee4007d 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IStatisticService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/IStatisticService.java
@@ -45,6 +45,8 @@ public interface IStatisticService {
     
     public TreeMap<Date, Map<String, ChannelStats>> getChannelStatsForPeriod(Date start, Date end, String nodeId, int periodSizeInMinutes);
     
+    public void deleteChannelStatsForPeriod(Date start, Date end, String nodeId);
+    
     public TreeMap<Date, Map<String, ChannelStats>> getNodeStatsForPeriod(Date start, Date end, String nodeId, int periodSizeInMinutes);
     
     public TreeMap<Date, HostStats> getHostStatsForPeriod(Date start, Date end, String nodeId, int periodSizeInMinutes);
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticService.java
index bc25f154bf..76b8b9ea5f 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticService.java
@@ -90,6 +90,10 @@ public TreeMap<Date, Map<String, ChannelStats>> getChannelStatsForPeriod(Date st
                 new ChannelStatsMapper(), start, end, nodeId);        
         return new ChannelStatsByPeriodMap(start, end, list, periodSizeInMinutes);
     }    
+    
+    public void deleteChannelStatsForPeriod(Date start, Date end, String nodeId) {
+        sqlTemplate.update(getSql("deleteChannelStatsSql"), start, end, nodeId);
+    }
 
     public TreeMap<Date, Map<String, ChannelStats>> getNodeStatsForPeriod(Date start, Date end,
             String nodeId, int periodSizeInMinutes) {
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticServiceSqlMap.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticServiceSqlMap.java
index 92ca667647..a6ec77c959 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticServiceSqlMap.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/StatisticServiceSqlMap.java
@@ -49,6 +49,11 @@ public StatisticServiceSqlMap(IDatabasePlatform platform, Map<String, String> re
 "  from $(node_host_channel_stats)                                            " + 
 "  where  start_time >= ? and end_time <= ? and node_id=? order by start_time asc   " );
         
+        putSql("deleteChannelStatsSql" , "" +
+"delete                                                 " +
+"  from $(node_host_channel_stats)                      " +
+"  where start_time >= ? and end_time <= ? and node_id=?");
+        
         putSql("selectNodeStatsSql", "" + 
 "select node_id, start_time, end_time,                                                    " + 
 "  sum(data_routed) as data_routed, sum(data_unrouted) as data_unrouted,                  " +