fix(sink): fix array<bool> error (#16221)

risingwavelabs · Apr 9, 2024 · 6f360ce · 6f360ce
1 parent e3ad87d
commit 6f360ce
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/connector/src/sink/starrocks.rs b/src/connector/src/sink/starrocks.rs
@@ -154,7 +154,7 @@ impl StarrocksSink {
     ) -> Result<bool> {
         match rw_data_type {
             risingwave_common::types::DataType::Boolean => {
-                Ok(starrocks_data_type.contains("tinyint"))
+                Ok(starrocks_data_type.contains("tinyint") | starrocks_data_type.contains("boolean"))
             }
             risingwave_common::types::DataType::Int16 => {
                 Ok(starrocks_data_type.contains("smallint"))