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 <[email protected]>
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;