diff --git a/src/datanode/src/region_server.rs b/src/datanode/src/region_server.rs index 15c295933735..8a68d81bd6f5 100644 --- a/src/datanode/src/region_server.rs +++ b/src/datanode/src/region_server.rs @@ -130,7 +130,7 @@ impl RegionServerHandler for RegionServer { for result in results { match result .map_err(BoxedError::new) - .context(servers_error::ExecuteGrpcRequestSnafu)? + .context(ExecuteGrpcRequestSnafu)? { Output::AffectedRows(rows) => affected_rows += rows, Output::Stream(_) | Output::RecordBatches(_) => { @@ -242,7 +242,9 @@ impl RegionServerInner { } RegionChange::Deregisters => { info!("Region {region_id} is deregistered from engine {engine_type}"); - self.region_map.remove(®ion_id); + self.region_map + .remove(®ion_id) + .map(|(id, engine)| engine.set_writable(id, false)); } } @@ -417,7 +419,7 @@ impl SchemaProvider for DummySchemaProvider { } } -/// For [TableProvider](datafusion::datasource::TableProvider) and [DummyCatalogList] +/// For [TableProvider](TableProvider) and [DummyCatalogList] #[derive(Clone)] struct DummyTableProvider { region_id: RegionId, diff --git a/src/frontend/src/instance.rs b/src/frontend/src/instance.rs index cda343d2a099..c61abd18f066 100644 --- a/src/frontend/src/instance.rs +++ b/src/frontend/src/instance.rs @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -pub mod distributed; +mod distributed; mod grpc; mod influxdb; mod opentsdb; diff --git a/src/frontend/src/statement/ddl.rs b/src/frontend/src/statement/ddl.rs index 711386128b2e..dea77dd0bfa1 100644 --- a/src/frontend/src/statement/ddl.rs +++ b/src/frontend/src/statement/ddl.rs @@ -111,7 +111,7 @@ impl StatementExecutor { let table_id = resp.table_id.context(error::UnexpectedSnafu { violated: "expected table_id", })?; - info!("Successfully created distributed table '{table_name}' with table id {table_id}"); + info!("Successfully created table '{table_name}' with table id {table_id}"); table_info.ident.table_id = table_id; let engine = table_info.meta.engine.to_string();