diff --git a/src/adapter/http/src/smart_protocol/ws_tungstenite_client.rs b/src/adapter/http/src/smart_protocol/ws_tungstenite_client.rs index c717d2060..ad70ebcc2 100644 --- a/src/adapter/http/src/smart_protocol/ws_tungstenite_client.rs +++ b/src/adapter/http/src/smart_protocol/ws_tungstenite_client.rs @@ -415,11 +415,12 @@ impl WsSmartTransferProtocolClient { } res = &mut export_task => { let join_res = res.int_err()?; - if let Err(task_err) = join_res { + if join_res.is_err() { tracing::error!( "File transfer failed, error is {:?}", - task_err + join_res ); + join_res?; } break; }