This is an automated email from the ASF dual-hosted git repository. danny0405 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push: new 675abf180bd [MINOR] Schema Converter should use default identity transform if not specified (#10178) 675abf180bd is described below commit 675abf180bd72627ef28c1e4f27a62eb271e22ec Author: Tim Brown <t...@onehouse.ai> AuthorDate: Mon Nov 27 23:21:56 2023 -0600 [MINOR] Schema Converter should use default identity transform if not specified (#10178) --- .../java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java | 2 +- 1 file changed, 1 insertion(+), 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 index 110c8cc2fb1..0f65dd338d0 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 class SchemaRegistryProvider extends SchemaProvider { 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;