This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 2dc7702 [improvement](connector) support write accept any schema
(#269)
2dc7702 is described below
commit 2dc7702ec51d1ae1f2f6c29a16ada83019238bd8
Author: gnehil <[email protected]>
AuthorDate: Tue Feb 25 11:17:40 2025 +0800
[improvement](connector) support write accept any schema (#269)
---
.../src/main/scala/org/apache/doris/spark/catalog/DorisTableBase.scala | 3 ++-
1 file changed, 2 insertions(+), 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 4cd5841..7f8fffd 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
@@ -47,7 +47,8 @@ abstract class DorisTableBase(identifier: Identifier, config:
DorisConfig, schem
override def capabilities(): util.Set[TableCapability] = {
Set(BATCH_READ,
BATCH_WRITE,
- STREAMING_WRITE).asJava
+ STREAMING_WRITE,
+ ACCEPT_ANY_SCHEMA).asJava
}
override def newScanBuilder(caseInsensitiveStringMap:
CaseInsensitiveStringMap): ScanBuilder = {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
