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;

Reply via email to