Add more logging

Author: shangm2

presto-main/src/main/java/com/facebook/presto/server/remotetask/ReactorNettyHttpClient.java

@@ -242,7 +242,7 @@ public <T, E extends Exception> HttpResponseFuture<T> executeAsync(Request airli
                         .responseSingle((response, bytes) -> bytes.asInputStream().zipWith(Mono.just(response)))
                         // Request timeout
                         .timeout(java.time.Duration.of(requestTimeout.toMillis(), MILLIS))
-                        .subscribe(t -> onSuccess(responseHandler, t.getT1(), t.getT2(), listenableFuture), e -> onError(listenableFuture, e), () -> onComplete(listenableFuture));
+                        .subscribe(t -> onSuccess(responseHandler, t.getT1(), t.getT2(), listenableFuture, uri), e -> onError(listenableFuture, e), () -> onComplete(listenableFuture));
                 break;
             case "POST":
                 byte[] postBytes = ((StaticBodyGenerator) airliftRequest.getBodyGenerator()).getBody();
@@ -278,15 +278,15 @@ public <T, E extends Exception> HttpResponseFuture<T> executeAsync(Request airli
                         .responseSingle((response, bytes) -> bytes.asInputStream().zipWith(Mono.just(response)))
                         // Request timeout
                         .timeout(java.time.Duration.of(requestTimeout.toMillis(), MILLIS))
-                        .subscribe(t -> onSuccess(responseHandler, t.getT1(), t.getT2(), listenableFuture), e -> onError(listenableFuture, e), () -> onComplete(listenableFuture));
+                        .subscribe(t -> onSuccess(responseHandler, t.getT1(), t.getT2(), listenableFuture, uri), e -> onError(listenableFuture, e), () -> onComplete(listenableFuture));
                 break;
             case "DELETE":
                 disposable = client.delete()
                         .uri(uri)
                         .responseSingle((response, bytes) -> bytes.asInputStream().zipWith(Mono.just(response)))
                         // Request timeout
                         .timeout(java.time.Duration.of(requestTimeout.toMillis(), MILLIS))
-                        .subscribe(t -> onSuccess(responseHandler, t.getT1(), t.getT2(), listenableFuture), e -> onError(listenableFuture, e), () -> onComplete(listenableFuture));
+                        .subscribe(t -> onSuccess(responseHandler, t.getT1(), t.getT2(), listenableFuture, uri), e -> onError(listenableFuture, e), () -> onComplete(listenableFuture));
                 break;
             default:
                 throw new UnsupportedOperationException("Unexpected request: " + airliftRequest);
@@ -341,7 +341,7 @@ public String getState()
         };
     }
 
-    public void onSuccess(ResponseHandler responseHandler, InputStream inputStream, HttpClientResponse response, SettableFuture<Object> listenableFuture)
+    public void onSuccess(ResponseHandler responseHandler, InputStream inputStream, HttpClientResponse response, SettableFuture<Object> listenableFuture, URI uri)
     {
         ListMultimap<HeaderName, String> responseHeaders = ArrayListMultimap.create();
         HttpHeaders headers = response.responseHeaders();
@@ -382,14 +382,14 @@ else if (name.equalsIgnoreCase(CONTENT_ENCODING_HEADER_NAME.toString())) {
             if (contentEncoding != null && !contentEncoding.equalsIgnoreCase("identity")) {
                 if (contentEncoding.equalsIgnoreCase("zstd")) {
                     streamHolder[0] = new ZstdInputStream(inputStream);
-                    log.info("onSuccess zstd");
+                    log.info("onSuccess zstd - URI: %s", uri);
                 }
                 else if (contentEncoding.equalsIgnoreCase("gzip")) {
                     streamHolder[0] = new GZIPInputStream(inputStream);
-                    log.info("onSuccess gzip");
+                    log.info("onSuccess gzip - URI: %s", uri);
                 }
                 else {
-                    throw new RuntimeException(format("Unsupported Content-Encoding: %s. Supported: zstd, gzip.", contentEncoding));
+                    throw new RuntimeException(format("Unsupported Content-Encoding: %s - URI: %s. Supported: zstd, gzip.", contentEncoding, uri));
                 }
             }