diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
index 54bc7038b1..e43b583745 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -1889,16 +1889,16 @@ public long insertData(Data data) {
 
     public long insertData(ISqlTransaction transaction, final Data data) {
         String sql = getSql("insertIntoDataSql");
-        String dateString = new Date().toString();
+        Date date = new Date();
         Object[] args = new Object[] { data.getTableName(), data.getDataEventType().getCode(), data.getRowData(),
                 data.getPkData(), data.getOldData(),
                 data.getTriggerHistory() != null ? data.getTriggerHistory().getTriggerHistoryId() : -1,
                 data.getChannelId(), data.getExternalData(), data.getNodeList(), data.isPreRouted() ? 1 : 0,
-                data.getTransactionId(), data.getSourceNodeId(), dateString };
+                data.getTransactionId(), data.getSourceNodeId(), date };
         int[] types = new int[] { Types.VARCHAR, Types.CHAR, Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.NUMERIC,
                 Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.NUMERIC, Types.VARCHAR, Types.VARCHAR, Types.TIMESTAMP };
         if (data.getCreateTime() != null) {
-            sql = sql.replace(dateString, "?");
+            sql = sql.replace(date.toString(), "?");
             args = ArrayUtils.add(args, data.getCreateTime());
             types = ArrayUtils.add(types, Types.TIMESTAMP);
         }