This is an automated email from the ASF dual-hosted git repository.
jerry-024 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/paimon-rust.git
The following commit(s) were added to refs/heads/main by this push:
new a1781ca fix: repair CI after partial-update merge (#314)
a1781ca is described below
commit a1781caca5dee25ef320ffd1f087831e660d879e
Author: QuakeWang <[email protected]>
AuthorDate: Tue May 12 17:18:03 2026 +0800
fix: repair CI after partial-update merge (#314)
---
crates/integrations/datafusion/tests/pk_tables.rs | 12 ++++++------
crates/paimon/src/table/cow_writer.rs | 1 -
crates/paimon/src/table/table_write.rs | 6 +++---
3 files changed, 9 insertions(+), 10 deletions(-)
diff --git a/crates/integrations/datafusion/tests/pk_tables.rs
b/crates/integrations/datafusion/tests/pk_tables.rs
index 3cc0c8b..fa0bd6f 100644
--- a/crates/integrations/datafusion/tests/pk_tables.rs
+++ b/crates/integrations/datafusion/tests/pk_tables.rs
@@ -79,9 +79,9 @@ async fn test_pk_basic_write_read() {
/// Partial-update merge engine: keep latest non-null value for each field.
#[tokio::test]
async fn test_pk_partial_update_fixed_bucket_e2e() {
- let (_tmp, handler) = setup_handler().await;
+ let (_tmp, sql_context) = setup_sql_context().await;
- handler
+ sql_context
.sql(
"CREATE TABLE paimon.test_db.t_partial_update (
id INT NOT NULL, v_int INT, v_str STRING,
@@ -91,7 +91,7 @@ async fn test_pk_partial_update_fixed_bucket_e2e() {
.await
.unwrap();
- handler
+ sql_context
.sql(
"INSERT INTO paimon.test_db.t_partial_update VALUES
(1, 10, 'old-1'),
@@ -103,7 +103,7 @@ async fn test_pk_partial_update_fixed_bucket_e2e() {
.await
.unwrap();
- handler
+ sql_context
.sql(
"INSERT INTO paimon.test_db.t_partial_update VALUES
(1, CAST(NULL AS INT), 'new-1'),
@@ -116,7 +116,7 @@ async fn test_pk_partial_update_fixed_bucket_e2e() {
.await
.unwrap();
- handler
+ sql_context
.sql(
"INSERT INTO paimon.test_db.t_partial_update VALUES
(1, 111, CAST(NULL AS STRING))",
@@ -127,7 +127,7 @@ async fn test_pk_partial_update_fixed_bucket_e2e() {
.await
.unwrap();
- let batches = handler
+ let batches = sql_context
.sql("SELECT id, v_int, v_str FROM paimon.test_db.t_partial_update
ORDER BY id")
.await
.unwrap()
diff --git a/crates/paimon/src/table/cow_writer.rs
b/crates/paimon/src/table/cow_writer.rs
index 7006f0f..c2b5e95 100644
--- a/crates/paimon/src/table/cow_writer.rs
+++ b/crates/paimon/src/table/cow_writer.rs
@@ -223,7 +223,6 @@ impl CopyOnWriteMergeWriter {
let target_file_size = core_options.target_file_size();
let file_compression = core_options.file_compression().to_string();
let file_compression_zstd_level =
core_options.file_compression_zstd_level();
- let file_format = core_options.file_format().to_string();
let write_buffer_size = core_options.write_parquet_buffer_size();
let file_format = core_options.file_format().to_string();
let schema_id = schema.id();
diff --git a/crates/paimon/src/table/table_write.rs
b/crates/paimon/src/table/table_write.rs
index b89a1c9..167cc85 100644
--- a/crates/paimon/src/table/table_write.rs
+++ b/crates/paimon/src/table/table_write.rs
@@ -926,7 +926,7 @@ mod tests {
None,
);
- TableWrite::new(&table, "test-user".to_string(), false).unwrap();
+ TableWrite::new(&table, "test-user".to_string()).unwrap();
}
#[tokio::test]
@@ -952,7 +952,7 @@ mod tests {
None,
);
- let mut table_write = TableWrite::new(&table, "test-user".to_string(),
false).unwrap();
+ let mut table_write = TableWrite::new(&table,
"test-user".to_string()).unwrap();
let err = table_write
.write_arrow_batch(&make_batch(vec![1], vec![10]))
.await
@@ -987,7 +987,7 @@ mod tests {
None,
);
- let mut table_write = TableWrite::new(&table, "test-user".to_string(),
false).unwrap();
+ let mut table_write = TableWrite::new(&table,
"test-user".to_string()).unwrap();
let err = table_write
.write_arrow_batch(&make_batch(vec![1], vec![10]))
.await
