diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/resources/SqlStatementResource.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/resources/SqlStatementResource.java index 1ee5f1030a40..322727aea92d 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/resources/SqlStatementResource.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/resources/SqlStatementResource.java @@ -595,7 +595,7 @@ private Optional getStatementStatus( )); } catch (DruidException e) { - if (e.getErrorCode().equals("notFound")) { + if (e.getErrorCode().equals("notFound") || e.getMessage().contains("Unable to contact overlord")) { return Optional.empty(); } throw e;