Skip to content

Commit 281baf0

Browse files
committed
fix
1 parent db64b98 commit 281baf0

File tree

1 file changed

+1
-1
lines changed
  • src/query/storages/fuse/src/operations

1 file changed

+1
-1
lines changed

src/query/storages/fuse/src/operations/append.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ impl FuseTable {
5151
pipeline: &mut Pipeline,
5252
table_meta_timestamps: TableMetaTimestamps,
5353
) -> Result<()> {
54-
let enable_stream_block_write = self.enable_stream_block_write(ctx.clone());
54+
let enable_stream_block_write = self.enable_stream_block_write(ctx.clone())?;
5555
if enable_stream_block_write {
5656
let properties = StreamBlockProperties::try_create(
5757
ctx.clone(),

0 commit comments

Comments
 (0)