diff --git a/river/sync.go b/river/sync.go
index 00e6f380..9639edbd 100644
--- a/river/sync.go
+++ b/river/sync.go
@@ -333,8 +333,7 @@ func (r *River) makeReqColumnData(col *schema.TableColumn, value interface{}) in
 	case schema.TYPE_DATETIME, schema.TYPE_TIMESTAMP:
 		switch v := value.(type) {
 		case string:
-			vt, _ := time.ParseInLocation(mysql.TimeFormat, string(v), time.Local)
-			return vt.Format(time.RFC3339)
+			return v
 		}
 	}