diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TransformService.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TransformService.java index 12364f390b..57915ca2d8 100644 --- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TransformService.java +++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TransformService.java @@ -230,7 +230,12 @@ public TransformTableNodeGroupLink mapRow(Row rs) { table.setTargetCatalogName(rs.getString("target_catalog_name")); table.setTargetSchemaName(rs.getString("target_schema_name")); table.setTargetTableName(rs.getString("target_table_name")); - table.setTransformPoint(TransformPoint.valueOf(rs.getString("transform_point"))); + try { + table.setTransformPoint(TransformPoint.valueOf(rs.getString("transform_point").toUpperCase())); + } catch (RuntimeException ex) { + log.warn("Invalid value provided for transform_point: {}", rs.getString("transform_point")); + throw ex; + } table.setTransformOrder(rs.getInt("transform_order")); table.setUpdateFirst(rs.getBoolean("update_first")); table.setDeleteAction(DeleteAction.valueOf(rs.getString("delete_action")));