Skip to content

Commit

Permalink
fix check
Browse files Browse the repository at this point in the history
  • Loading branch information
xxhZs committed Oct 24, 2023
1 parent 465b6d6 commit fb8d1ca
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/connector/src/sink/clickhouse.rs
Original file line number Diff line number Diff line change
Expand Up @@ -490,9 +490,9 @@ impl ClickHouseSinkWriter {
}
Op::Delete | Op::UpdateDelete => {
if !self.clickhouse_engine.is_collapsing_engine() {
return Err(SinkError::ClickHouse(format!(
"Clickhouse engine don't support upsert",
)));
return Err(SinkError::ClickHouse(
"Clickhouse engine don't support upsert".to_string(),
));
}
clickhouse_filed_vec.push(ClickHouseFieldWithNull::WithoutSome(
ClickHouseField::Int8(-1),
Expand Down

0 comments on commit fb8d1ca

Please sign in to comment.