diff --git a/coral-schema/src/main/java/com/linkedin/coral/schema/avro/SchemaUtilities.java b/coral-schema/src/main/java/com/linkedin/coral/schema/avro/SchemaUtilities.java index 6249f88e3..9c33a6b06 100644 --- a/coral-schema/src/main/java/com/linkedin/coral/schema/avro/SchemaUtilities.java +++ b/coral-schema/src/main/java/com/linkedin/coral/schema/avro/SchemaUtilities.java @@ -132,6 +132,9 @@ static Schema getCasePreservedSchemaFromTblProperties(@Nonnull final Table table // Then, try dali.row.schema if (Strings.isNullOrEmpty(schemaStr)) { schemaStr = table.getParameters().get(DALI_ROW_SCHEMA); + if (!Strings.isNullOrEmpty(schemaStr)) { + schemaStr = schemaStr.replaceAll("\n", "\\\\n"); + } } if (!Strings.isNullOrEmpty(schemaStr)) {