Skip to content

Commit 2093cd1

Browse files
committed
Better exception
1 parent f44be2f commit 2093cd1

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

services/src/main/java/org/apache/druid/cli/CliPeonLoadSpecHolder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public LookupLoadingSpec getLookupLoadingSpec()
5151
{
5252
final Task task = taskProvider.get();
5353
if (task == null) {
54-
throw DruidException.defensive("blah");
54+
throw DruidException.defensive("task is null for taskProvider[%s]?!", taskProvider);
5555
}
5656
return task.getLookupLoadingSpec();
5757
}
@@ -61,7 +61,7 @@ public BroadcastDatasourceLoadingSpec getBroadcastDatasourceLoadingSpec()
6161
{
6262
final Task task = taskProvider.get();
6363
if (task == null) {
64-
throw DruidException.defensive("blah");
64+
throw DruidException.defensive("task is null for taskProvider[%s]?!", taskProvider);
6565
}
6666
return task.getBroadcastDatasourceLoadingSpec();
6767
}

services/src/main/java/org/apache/druid/cli/CliPeonTaskHolder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public String getDataSource()
4848
{
4949
final Task task = taskProvider.get();
5050
if (task == null) {
51-
throw DruidException.defensive("blah");
51+
throw DruidException.defensive("task is null for taskProvider[%s]?!", taskProvider);
5252
}
5353
return task.getDataSource();
5454
}
@@ -58,7 +58,7 @@ public String getTaskId()
5858
{
5959
final Task task = taskProvider.get();
6060
if (task == null) {
61-
throw DruidException.defensive("blah");
61+
throw DruidException.defensive("task is null for taskProvider[%s]?!", taskProvider);
6262
}
6363
return task.getId();
6464
}

0 commit comments

Comments
 (0)