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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
