[MINOR] Schema Converter should use default identity transform if not…

… specified (#10178)
apache · Nov 28, 2023 · 675abf1 · 675abf1
1 parent fb062df
commit 675abf1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java
@@ -96,7 +96,7 @@ public interface SchemaConverter {
   public Schema parseSchemaFromRegistry(String registryUrl) {
     String schema = fetchSchemaFromRegistry(registryUrl);
     try {
-      String schemaConverter = getStringWithAltKeys(config, HoodieSchemaProviderConfig.SCHEMA_CONVERTER);
+      String schemaConverter = getStringWithAltKeys(config, HoodieSchemaProviderConfig.SCHEMA_CONVERTER, true);
       SchemaConverter converter = !StringUtils.isNullOrEmpty(schemaConverter)
           ? ReflectionUtils.loadClass(schemaConverter)
           : s -> s;