Skip to content

Commit

Permalink
Revert "Remove SetThreadName as it consumes a significant amount of c…
Browse files Browse the repository at this point in the history
…pu time"

This reverts commit 771756b.

The scheduler changes can result in smaller queries being starved
by bigger queries due to the introduction of global per-node queues.
Reverting for now so we can release. We'll revisit later.
  • Loading branch information
martint committed Mar 12, 2014
1 parent 0a48214 commit 069a441
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -280,8 +280,10 @@ public synchronized void setOutputBuffers(OutputBuffers newOutputBuffers)
@Override
public synchronized int getPartitionedSplitCount()
{
int splitCount = pendingSplits.get(planFragment.getPartitionedSource()).size();
return splitCount + taskInfo.get().getStats().getQueuedPartitionedDrivers() + taskInfo.get().getStats().getRunningPartitionedDrivers();
try (SetThreadName setThreadName = new SetThreadName("HttpRemoteTask-%s", taskId)) {
int splitCount = pendingSplits.get(planFragment.getPartitionedSource()).size();
return splitCount + taskInfo.get().getStats().getQueuedPartitionedDrivers() + taskInfo.get().getStats().getRunningPartitionedDrivers();
}
}

@Override
Expand Down

0 comments on commit 069a441

Please sign in to comment.