Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-17 07:25:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix bugs with finding indexing workers to assign

Browse Source
This commit is contained in:
fjy 2014-02-03 16:33:06 -08:00
parent d4eba49722
commit f4b6165307
3 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/main/java/io/druid/client/DruidServer.java
View File

@ -136,6 +136,11 @@ public class DruidServer implements Comparable
return Collections.unmodifiableMap(segments);
}
public boolean isAssignable()
{
return getType().equalsIgnoreCase("historical") || getType().equalsIgnoreCase("bridge");
}
public boolean isRealtime()
{
return getType().equalsIgnoreCase("realtime");

2
server/src/main/java/io/druid/server/bridge/DruidClusterBridge.java
View File

@ -291,7 +291,7 @@ public class DruidClusterBridge
DruidServer input
)
{
return !input.isRealtime();
return input.isAssignable();
}
}
);

2
server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java
View File

@ -777,7 +777,7 @@ public class DruidCoordinator
DruidServer input
)
{
return !input.isRealtime();
return input.isAssignable();
}
}
);