Add blocked drivers to StatementStats and StageStats
@@ -625,7 +625,7 @@ public class StatementResource
.setNodes(globalUniqueNodes(outputStage).size())
.setTotalSplits(queryStats.getTotalDrivers())
.setQueuedSplits(queryStats.getQueuedDrivers())
- .setRunningSplits(queryStats.getRunningDrivers())
+ .setRunningSplits(queryStats.getRunningDrivers() + queryStats.getBlockedDrivers())
.setCompletedSplits(queryStats.getCompletedDrivers())
.setUserTimeMillis(queryStats.getTotalUserTime().toMillis())
.setCpuTimeMillis(queryStats.getTotalCpuTime().toMillis())
@@ -663,7 +663,7 @@ public class StatementResource
.setNodes(uniqueNodes.size())
.setTotalSplits(stageStats.getTotalDrivers())
.setQueuedSplits(stageStats.getQueuedDrivers())
- .setRunningSplits(stageStats.getRunningDrivers())
+ .setRunningSplits(stageStats.getRunningDrivers() + stageStats.getBlockedDrivers())
.setCompletedSplits(stageStats.getCompletedDrivers())
.setUserTimeMillis(stageStats.getTotalUserTime().toMillis())
.setCpuTimeMillis(stageStats.getTotalCpuTime().toMillis())
