You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/09/27 10:49:34 UTC

[flink] branch master updated: [FLINK-10390][metrics][datadog] Close responseBody

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 1e6764b  [FLINK-10390][metrics][datadog] Close responseBody
1e6764b is described below

commit 1e6764bbb637a9e323693842c1604a5aebf48a64
Author: zentol <ch...@apache.org>
AuthorDate: Mon Sep 24 15:08:24 2018 +0200

    [FLINK-10390][metrics][datadog] Close responseBody
---
 .../main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java b/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
index be11e48..9125629 100644
--- a/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
+++ b/flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java
@@ -115,7 +115,7 @@ public class DatadogHttpClient {
 
 		@Override
 		public void onResponse(Call call, Response response) throws IOException {
-			// Do nothing
+			response.close();
 		}
 	}
 }