commit 7206f680c331efad175132829024c3a62f6940f2
author wudi <676366545@qq.com> Tue Jun 17 16:10:47 2025 +0800
committer GitHub <noreply@github.com> Tue Jun 17 16:10:47 2025 +0800
tree 6588fccbc9d6aab4a84d385f259093736409e32f
parent 8dcb5225a86c3d82fceccb3d65e30720e54d06e4

update schema get

spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala

diff --git a/spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala b/spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala
index 50af0fa..ea213a8 100644
--- a/spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala
+++ b/spark-doris-connector/spark-doris-connector-spark-3-base/src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala
@@ -59,7 +59,7 @@
 
   override def newWriteBuilder(logicalWriteInfo: LogicalWriteInfo): WriteBuilder = {
     config.setProperty(DorisOptions.DORIS_TABLE_IDENTIFIER, name())
-    createWriteBuilder(config, logicalWriteInfo.schema())
+    createWriteBuilder(config, schema())
   }
 
   private implicit def dorisSchemaToStructType(dorisSchema: Schema): StructType = {