This is an automated email from the ASF dual-hosted git repository. diwu pushed a commit to branch JNSimba-patch-5 in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
commit 7206f680c331efad175132829024c3a62f6940f2 Author: wudi <[email protected]> AuthorDate: Tue Jun 17 16:10:47 2025 +0800 update schema get --- .../src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 @@ abstract class DorisTableBase(identifier: Identifier, config: DorisConfig, schem 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 = { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
