[query/sessions] remove work stealing
@@ -73,30 +73,6 @@ impl FuseQueryContext {
}
}
}
-
- // Try fetching from other nodes if the queue is empty and in cluster mode.
- if partitions.is_empty() && !self.cluster.lock()?.is_empty()? {
- let uuid = self.get_id()?;
- let nodes = self.cluster.lock()?.get_nodes()?;
- for node in &nodes {
- // Not local node, try to fetch.
- if !node.is_local() {
- let mut parts = async_std::task::block_on(async {
- let client = GrpcClient::create(node.address.clone());
- client.fetch_partition(1, uuid.clone()).await
- })?;
- info!(
- "Node: {:?} stealing partitions:{:?} from {:?}",
- uuid, parts, node
- );
- if !parts.is_empty() {
- partitions.append(parts.as_mut());
- break;
- }
- }
- }
- }
-
Ok(partitions)
}
