diff --git a/core/services/memcached/src/core.rs b/core/services/memcached/src/core.rs index 1221bb08ed7f..2b9a49533245 100644 --- a/core/services/memcached/src/core.rs +++ b/core/services/memcached/src/core.rs @@ -23,7 +23,6 @@ use fastpool::bounded; use opendal_core::raw::*; use opendal_core::*; use std::io; -use std::net::SocketAddr; use std::pin::Pin; use std::task::{Context, Poll}; use tokio::io::{AsyncRead, AsyncWrite, ReadBuf}; @@ -42,10 +41,7 @@ pub enum SocketStream { impl SocketStream { pub async fn connect_tcp(addr_str: &str) -> io::Result { - let socket_addr: SocketAddr = addr_str - .parse() - .map_err(|e| io::Error::new(io::ErrorKind::InvalidInput, e))?; - let stream = TcpStream::connect(socket_addr).await?; + let stream = TcpStream::connect(addr_str).await?; Ok(SocketStream::Tcp(stream)) }