diff --git a/src/stream/src/from_proto/chain.rs b/src/stream/src/from_proto/chain.rs index a72ddfa61e721..4dc4f39090e8c 100644 --- a/src/stream/src/from_proto/chain.rs +++ b/src/stream/src/from_proto/chain.rs @@ -64,8 +64,7 @@ impl ExecutorBuilder for ChainExecutorBuilder { Schema { fields: output_schema_fields, } - } - else if matches!(node.chain_type(), ChainType::Backfill) { + } else if matches!(node.chain_type(), ChainType::Backfill) { Schema::new( output_indices .iter()