Github user bitblender commented on a diff in the pull request:
https://github.com/apache/drill/pull/921#discussion_r149542196
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java ---
@@ -348,6 +354,21 @@ public void run() {
*/
}
+ /*
+ Check if the foreman is ONLINE. If not dont accept any new queries.
+ */
+ public void checkForemanState() throws ForemanException{
+ DrillbitEndpoint foreman = drillbitContext.getEndpoint();
+ Collection<DrillbitEndpoint> dbs = drillbitContext.getAvailableBits();
--- End diff --
Maybe add it to the DrillbitContext class ?
---
