From dca8ea16678f5e2ead0dce50915b8694a8421a5b Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Wed, 7 May 2025 19:28:03 -0700 Subject: [PATCH] Fix resultFormat of SegmentLoadStatusFetcher. In #17846, SegmentLoadStatusFetcher was changed to send a resultFormat of "text/plain" rather than "objectLines". This effectively broke the feature of waiting for load status, since the load status would always be FAILED. --- .../apache/druid/msq/exec/SegmentLoadStatusFetcher.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java index 814f4d8a63db..32058d161f28 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java @@ -237,8 +237,12 @@ private VersionLoadStatus fetchLoadStatusFromBroker() throws Exception { ClientSqlQuery clientSqlQuery = new ClientSqlQuery( StringUtils.format(LOAD_QUERY, datasource, versionsConditionString), - ResultFormat.OBJECTLINES.contentType(), - false, false, false, null, null + ResultFormat.OBJECTLINES.name(), + false, + false, + false, + null, + null ); final String response = FutureUtils.get(brokerClient.submitSqlQuery(clientSqlQuery), true);