escape newline for dali row schema string (#91)

linkedin · May 25, 2021 · b018577 · b018577
1 parent a1dfb75
commit b018577
Showing 1 changed file with 3 additions and 0 deletions.
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
@@ -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)) {