diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/HoodieBootstrapSchemaProvider.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/HoodieBootstrapSchemaProvider.java index c8e552b1a8dd6..ce4c42ba16654 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/HoodieBootstrapSchemaProvider.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/HoodieBootstrapSchemaProvider.java @@ -48,7 +48,7 @@ public HoodieBootstrapSchemaProvider(HoodieWriteConfig writeConfig) { public final Schema getBootstrapSchema(HoodieEngineContext context, List>> partitions) { if (writeConfig.getSchema() != null) { // Use schema specified by user if set - Schema userSchema = Schema.parse(writeConfig.getSchema()); + Schema userSchema = new Schema.Parser().parse(writeConfig.getSchema()); if (!HoodieAvroUtils.getNullSchema().equals(userSchema)) { return userSchema; }