Fix thread name: should be master executor not input
This commit is contained in:
parent
6a73265a06
commit
10a6b57be6
|
|
@ -92,7 +92,7 @@ public class NanoScheduler<InputType, MapType, ReduceType> {
|
|||
runningMapJobSlots = new Semaphore(this.bufferSize);
|
||||
|
||||
this.inputExecutor = Executors.newSingleThreadExecutor(new NamedThreadFactory("NS-input-thread-%d"));
|
||||
this.masterExecutor = Executors.newSingleThreadExecutor(new NamedThreadFactory("NS-input-thread-%d"));
|
||||
this.masterExecutor = Executors.newSingleThreadExecutor(new NamedThreadFactory("NS-master-thread-%d"));
|
||||
}
|
||||
|
||||
// start timing the time spent outside of the nanoScheduler
|
||||
|
|
|
|||
Loading…
Reference in New Issue