diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
index 8da075c3d7..ffe41c7bc6 100644
--- a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
+++ b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/IncomingBatchService.java
@@ -23,6 +23,7 @@
 
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.sql.Types;
 import java.util.List;
 
 import org.apache.commons.logging.Log;
@@ -107,13 +108,22 @@ public int updateIncomingBatch(IncomingBatch status) {
     }
 
     public void insertIncomingBatchHistory(IncomingBatchHistory history) {
-        jdbcTemplate.update(insertIncomingBatchHistorySql, new Object[] { Long.valueOf(history.getBatchId()),
-                history.getNodeId(), history.getStatus().toString(), history.getNetworkMillis(),
-                history.getFilterMillis(), history.getDatabaseMillis(), history.getHostName(),
-                history.getByteCount(), history.getStatementCount(), history.getFallbackInsertCount(),
-                history.getFallbackUpdateCount(), history.getMissingDeleteCount(),
-                history.getFailedRowNumber(), history.getStartTime(), history.getEndTime(),
-                history.getSqlState(), history.getSqlCode(), history.getSqlMessage() });
+        try {
+            jdbcTemplate.update(insertIncomingBatchHistorySql, new Object[] {
+                    Long.valueOf(history.getBatchId()), history.getNodeId(), history.getStatus().toString(),
+                    history.getNetworkMillis(), history.getFilterMillis(), history.getDatabaseMillis(),
+                    history.getHostName(), history.getByteCount(), history.getStatementCount(),
+                    history.getFallbackInsertCount(), history.getFallbackUpdateCount(),
+                    history.getMissingDeleteCount(), history.getFailedRowNumber(), history.getStartTime(),
+                    history.getEndTime(), history.getSqlState(), history.getSqlCode(),
+                    history.getSqlMessage() }, new int[] { Types.INTEGER, Types.VARCHAR, Types.CHAR,
+                    Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.VARCHAR, Types.INTEGER, Types.INTEGER,
+                    Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.TIMESTAMP,
+                    Types.TIMESTAMP, Types.VARCHAR, Types.INTEGER, Types.VARCHAR });
+        } catch (RuntimeException ex) {
+            logger.error(ex, ex);
+            throw ex;
+        }
     }
 
     class IncomingBatchMapper implements RowMapper {