diff --git a/sdk/core/azure-core/src/main/java/com/azure/core/http/policy/HttpLoggingPolicy.java b/sdk/core/azure-core/src/main/java/com/azure/core/http/policy/HttpLoggingPolicy.java
index 78916a4b2072..958a88324356 100644
--- a/sdk/core/azure-core/src/main/java/com/azure/core/http/policy/HttpLoggingPolicy.java
+++ b/sdk/core/azure-core/src/main/java/com/azure/core/http/policy/HttpLoggingPolicy.java
@@ -17,7 +17,6 @@
 import com.fasterxml.jackson.databind.SerializationFeature;
 import reactor.core.publisher.Mono;
 
-import java.net.MalformedURLException;
 import java.net.URL;
 import java.nio.charset.StandardCharsets;
 import java.util.Locale;
@@ -83,13 +82,9 @@ public Mono<HttpResponse> process(HttpPipelineCallContext context, HttpPipelineN
     private Mono<Void> logRequest(final ClientLogger logger, final HttpRequest request) {
         final HttpLogDetailLevel httpLogLevel = httpLogOptions.getLogLevel();
         if (httpLogLevel.shouldLogUrl()) {
-            try {
-                UrlBuilder requestUrl = UrlBuilder.parse(request.getUrl());
-                requestUrl.setQuery(getAllowedQueryString(request.getUrl().getQuery()));
-                logger.info("--> {} {}", request.getHttpMethod(), requestUrl.toUrl());
-            } catch (MalformedURLException ex) {
-                return Mono.error(logger.logExceptionAsWarning(new IllegalStateException("Invalid request URL.")));
-            }
+            UrlBuilder requestUrl = UrlBuilder.parse(request.getUrl());
+            requestUrl.setQuery(getAllowedQueryString(request.getUrl().getQuery()));
+            logger.info("--> {} {}", request.getHttpMethod(), requestUrl.toString());
         }
 
         if (httpLogLevel.shouldLogHeaders()) {
@@ -196,9 +191,11 @@ private Function<HttpResponse, Mono<HttpResponse>> logResponseDelegate(final Cli
                 bodySize = contentLengthString + "-byte";
             }
             HttpLogDetailLevel httpLogLevel = httpLogOptions.getLogLevel();
-            // HttpResponseStatus responseStatus = HttpResponseStatus.valueOf(response.statusCode());
             if (httpLogLevel.shouldLogUrl()) {
-                logger.info("<-- {} {} ({} ms, {} body)", response.getStatusCode(), url, tookMs, bodySize);
+                UrlBuilder requestUrl = UrlBuilder.parse(url);
+                requestUrl.setQuery(getAllowedQueryString(url.getQuery()));
+                logger.info("<-- {} {} ({} ms, {} body)", response.getStatusCode(), requestUrl.toString(), tookMs,
+                    bodySize);
             }
 
             if (httpLogLevel.shouldLogHeaders()) {