diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java
index a4061414fb..148bec920a 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/DbCompare.java
@@ -20,11 +20,13 @@
  */
 package org.jumpmind.symmetric.io;
 
+import java.io.Closeable;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
 import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.time.DurationFormatUtils;
 import org.jumpmind.db.model.Column;
@@ -182,6 +184,8 @@ protected TableReport compareTables(DbCompareTables tables) {
             }
         } finally {
             diffWriter.close();
+            IOUtils.closeQuietly(sourceCursor);
+            IOUtils.closeQuietly(targetCursor);
         }
 
         return tableReport;
@@ -483,7 +487,7 @@ public void setUseSymmetricConfig(boolean useSymmetricConfig) {
         this.useSymmetricConfig = useSymmetricConfig;
     }
 
-    class CountingSqlReadCursor implements ISqlReadCursor<Row> {
+    class CountingSqlReadCursor implements ISqlReadCursor<Row>, Closeable {
 
         ISqlReadCursor<Row> wrapped;
         int count = 0;