update

apache · Jun 16, 2022 · bacc544 · bacc544
1 parent fa73fb9
commit bacc544
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...di-spark/src/main/scala/org/apache/spark/sql/hudi/command/payload/ExpressionPayload.scala b/...di-spark/src/main/scala/org/apache/spark/sql/hudi/command/payload/ExpressionPayload.scala
@@ -214,7 +214,9 @@ class ExpressionPayload(record: GenericRecord,
    * Init the table schema.
    */
   private def initWriteSchemaIfNeed(properties: Properties): Unit = {
-    writeSchema = setWriteSchema(properties)
+    if (writeSchema == null) {
+      writeSchema = setWriteSchema(properties)
+    }
   }
 
   /**