Skip to content

Commit 3b54d16

Browse files
committed
fix conflict + fmt
1 parent 5ea3427 commit 3b54d16

File tree

2 files changed

+1
-12
lines changed

2 files changed

+1
-12
lines changed

src/frontend/src/catalog/root_catalog.rs

-11
Original file line numberDiff line numberDiff line change
@@ -679,17 +679,6 @@ impl Catalog {
679679
self.table_by_id.values()
680680
}
681681

682-
pub fn get_schema_by_table_id(
683-
&self,
684-
db_name: &str,
685-
table_id: &TableId,
686-
) -> CatalogResult<&SchemaCatalog> {
687-
self.database_by_name
688-
.get(db_name)
689-
.and_then(|db| db.find_schema_containing_table_id(table_id))
690-
.ok_or_else(|| CatalogError::NotFound("schema with table", table_id.to_string()))
691-
}
692-
693682
// Used by test_utils only.
694683
pub fn alter_table_name_by_id(&mut self, table_id: &TableId, table_name: &str) {
695684
let (mut database_id, mut schema_id) = (0, 0);

src/frontend/src/optimizer/rule/table_function_to_internal_backfill_progress.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ impl FallibleRule for TableFunctionToInternalBackfillProgressRule {
120120
let (agg, _rewritten_select_exprs, _rewritten_having_exprs) =
121121
LogicalAgg::create(select_exprs, group_key, None, union.into())?;
122122
let project = LogicalProject::new(
123-
agg.into(),
123+
agg,
124124
vec![
125125
ExprImpl::InputRef(Box::new(InputRef {
126126
index: 0,

0 commit comments

Comments
 (0)