We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent dd63852 commit 47c5931Copy full SHA for 47c5931
rust/src/hdfs/proxy.rs
@@ -154,10 +154,11 @@ impl NameServiceProxy {
154
}
155
// RPCError indicates the call was successfully attempted but had an error, so should be returned immediately
156
Err(HdfsError::RPCError(exception, msg)) if !Self::is_retriable(&exception) => {
157
- warn!("{}: {}", exception, msg);
158
return Err(Self::convert_rpc_error(exception, msg));
159
160
Err(_) if attempts >= self.proxy_connections.len() - 1 => return result,
+ // Retriable error, do nothing and try the next connection
161
+ Err(HdfsError::RPCError(_, _)) => (),
162
Err(e) => {
163
warn!("{:?}", e);
164
0 commit comments