Doris Spark Connector
This document lists Doris Spark Connector release notes in reverse chronological order.
26.0.0
Source: Spark Doris Connector 26.0.0
Spark Connector
Features and Improvements
- Enabled gzip compression by default for Stream Load writes. #356
- Added logs for Arrow Flight reads. #354
- Supported HTTP requests with UTF-8 charset encoding. #347
Bug Fixes
- Fixed column projection issues in Spark 3.3, 3.4, and 3.5. #353
Thanks
- @JNSimba
- @gnehil
25.2.0
Source: Spark Doris Connector 25.2.0
Spark Connector
Features and Improvements
- Added FE retry and load balancing strategy for Doris Flight SQL Reader. #318
- Added load balancing strategy for frontends and backends. #329
- Added schema-less option. #332
Bug Fixes
- Fixed filter pushdown issues with
ORin SQL. #317 - Fixed an issue where retries might get stuck when an FE hangs. #331
- Improved
accept_any_schemaoption handling. #326 - Fixed V2Expression build errors. #339
- Fixed an issue where
doris.benodesdid not take effect. #346
Thanks
- @JNSimba
- @wanggx
- @wary
25.1.0
Source: Spark Doris Connector Release Note 25.1.0
Spark Connector
Features and Improvements
- Supported overwrite for DataSource V2. #281
- Supported reading the
DECIMAL128type. #290 - Added compatibility for reading the IP data type. #289
- Improved BE Thrift read logs and Stream Load logs. #279 #313
- Added Doris source and sink integration test cases, and added Spark 3.2, 3.4, and 3.5 CI coverage. #296 #297 #302 #312
- Enhanced FE node port checks and improved write performance. #303
- Added retry intervals when load fails. #307
- Added code checks for FE requests. #309
- Removed unused code after refactoring. #295
Bug Fixes
- Fixed compilation for filter
INclauses. #277 - Fixed unit tests for row converter and schema converter. #278
- Fixed a null pointer exception when committing a transaction for an empty partition. #286
- Fixed an issue where pruned column results were not pushed down. #287
- Fixed performance degradation caused by an interval configuration mistake. #294
- Fixed issues when Spark pushes down
CASE WHENexpressions. #300 - Fixed an issue where loading tasks got stuck when Stream Load ended unexpectedly. #305
- Fixed an issue where queries could not run when UTF-8 encoding was pushed down. #311
- Fixed rename conflicts for
ArrowWriterandArrowUtil. #315
Spark Load
Features and Improvements
- Supported loading Hadoop configuration from resources. #280
Thanks
- @aoyuEra
- @gnehil
- @JNSimba
- @IsmailTosunTnyl
- @qg-lin
- @vinlee19
- @wary
25.0.1
Source: Spark Doris Connector Release Note 25.0.1
Spark Connector
Features and Improvements
- Supported accepting tables with any schema. #269
- Added logs for Stream Load responses. #271
- Improved log messages. #274
- Added release scripts. #275
Bug Fixes
Spark Load
Bug Fixes
- Fixed unit test cases and added CI build checks. #272
Thanks
- @gnehil
- @JNSimba
25.0.0
Source: Spark Doris Connector Release Note 25.0.0
Spark Connector
Features and Improvements
- Supported Spark DataSource V2 API pushdown. #250
- Supported partial limit pushdown for Spark 3.2 and later. #257
- Added compatibility for FE API changes. #260
- Supported
CREATE TABLEstatements for Spark 3.3 and later. #264
Bug Fixes
- Fixed a driver exception when the Spark catalog gets a JDBC connection. #251
- Fixed a data conversion exception when reading the date type. #253
- Fixed an exception caused by loading the Arrow JDBC driver when loading the MySQL driver. #254
- Fixed an issue where schema column order was inconsistent with data column order. #256
- Fixed an exception when reading JSON type data through Flight SQL. #263
- Fixed an exception when reading date type data with
spark.sql.datetime.java8API.enabledenabled. #265
Spark Load
Features and Improvements
- Supported job execution based on object storage. #266
Thanks
- @gnehil
- @JNSimba