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 index 110c8cc2fb139..0f65dd338d035 100644 --- 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;