Skip to content

Commit 95cac9c

Browse files
committed
Move table_config check
1 parent 355d82c commit 95cac9c

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

kernel/src/table_changes/log_replay.rs

+4-3
Original file line numberDiff line numberDiff line change
@@ -197,10 +197,11 @@ fn process_cdf_commit(
197197
)
198198
);
199199
}
200-
table_configuration
201-
.can_read_cdf()
202-
.map_err(|_| Error::change_data_feed_unsupported(commit_file.version))?;
203200
}
201+
202+
table_configuration
203+
.can_read_cdf()
204+
.map_err(|_| Error::change_data_feed_unsupported(commit_file.version))?;
204205
// We resolve the remove deletion vector map after visiting the entire commit.
205206
if has_cdc_action {
206207
remove_dvs.clear();

0 commit comments

Comments
 (0)