diff --git a/symmetric-db/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDmlStatement.java b/symmetric-db/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDmlStatement.java
index c5900fd748..4c4cd87471 100644
--- a/symmetric-db/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDmlStatement.java
+++ b/symmetric-db/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDmlStatement.java
@@ -143,7 +143,7 @@ protected void appendColumnEquals(StringBuilder sql, Column column) {
 
         if (typeToCast != null) {
             sql.append(quote).append(column.getName()).append(quote)
-                    .append(" = cast(? as ").append(typeToCast).append(")").append(",");
+                    .append(" = cast(? as ").append(typeToCast).append(")");
         } else if (column.getJdbcTypeName() != null && (
                 column.getJdbcTypeName().toUpperCase().contains(TypeMap.GEOMETRY) ||
                 column.getJdbcTypeName().toUpperCase().contains(TypeMap.GEOGRAPHY))) {
diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDatabasePlatform.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDatabasePlatform.java
index f908429f6b..505945f5f6 100644
--- a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDatabasePlatform.java
+++ b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/postgresql/PostgreSqlDatabasePlatform.java
@@ -357,4 +357,11 @@ public String getSliceTableSql(String columnName, int sliceNum, int totalSlices)
         return "ascii(substring(" + columnName + ", 1, 1)) % " + totalSlices + " = " + sliceNum;
     }
 
+    @Override
+    public boolean canColumnBeUsedInWhereClause(Column column) {
+        if (column.getJdbcTypeName() != null && column.getJdbcTypeName().startsWith("json")) {
+            return false;
+        }
+        return true;
+    }
 }