You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ka...@apache.org on 2025/05/08 04:36:50 UTC
(druid) branch master updated: Fix resultFormat of SegmentLoadStatusFetcher. (#17987)
This is an automated email from the ASF dual-hosted git repository.
karan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 04ad5c5f8ae Fix resultFormat of SegmentLoadStatusFetcher. (#17987)
04ad5c5f8ae is described below
commit 04ad5c5f8aed39181e20e2e6f4dbc60f294e250a
Author: Gian Merlino <gi...@gmail.com>
AuthorDate: Wed May 7 21:36:43 2025 -0700
Fix resultFormat of SegmentLoadStatusFetcher. (#17987)
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.
---
.../java/org/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 814f4d8a63d..32058d161f2 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 @@ public class SegmentLoadStatusFetcher implements AutoCloseable
{
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);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org