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);