From 137f90a1ea5ea210c4893623e59db6c986eef92b Mon Sep 17 00:00:00 2001 From: Dilli-Babu-Godari Date: Wed, 1 Oct 2025 14:12:00 +0530 Subject: [PATCH] Fix Druid connector to use strict application/json content type Druid 34.0.0 and above enforces stricter content-type validation on its SQL endpoint and only accepts requests with `Content-Type: application/json`. The Presto Druid connector previously sent requests with `application/json; charset=UTF-8`, which results in `415 Unsupported Media Type` errors against newer Druid versions. --- .../src/main/java/com/facebook/presto/druid/DruidClient.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/presto-druid/src/main/java/com/facebook/presto/druid/DruidClient.java b/presto-druid/src/main/java/com/facebook/presto/druid/DruidClient.java index 68e6742717dff..50a6fe55d8bde 100644 --- a/presto-druid/src/main/java/com/facebook/presto/druid/DruidClient.java +++ b/presto-druid/src/main/java/com/facebook/presto/druid/DruidClient.java @@ -64,7 +64,6 @@ import static com.google.common.collect.ImmutableList.toImmutableList; import static com.google.common.collect.Iterables.getOnlyElement; import static com.google.common.net.HttpHeaders.CONTENT_TYPE; -import static com.google.common.net.MediaType.JSON_UTF_8; import static java.lang.String.format; import static java.net.HttpURLConnection.HTTP_OK; import static java.util.Locale.ENGLISH; @@ -201,7 +200,7 @@ public InputStream ingestData(DruidIngestTask ingestTask) private static Request.Builder setContentTypeHeaders(Request.Builder requestBuilder) { return requestBuilder - .setHeader(CONTENT_TYPE, JSON_UTF_8.toString()); + .setHeader(CONTENT_TYPE, "application/json"); } private static byte[] createRequestBody(String query, DruidResultFormat resultFormat, boolean queryHeader)