diff --git llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java index f04fe15..69728f3 100644 --- llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java +++ llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java @@ -53,6 +53,7 @@ import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; +import com.google.common.util.concurrent.ThreadFactoryBuilder; public class LlapIoImpl implements LlapIo { public static final Log LOG = LogFactory.getLog(LlapIoImpl.class); @@ -106,7 +107,8 @@ private LlapIoImpl(Configuration conf) throws IOException { } // Arbitrary thread pool. Listening is used for unhandled errors for now (TODO: remove?) int numThreads = HiveConf.getIntVar(conf, HiveConf.ConfVars.LLAP_IO_THREADPOOL_SIZE); - executor = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(numThreads)); + executor = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(numThreads, + new ThreadFactoryBuilder().setNameFormat("IO-Elevator-Thread-%d").build())); // TODO: this should depends on input format and be in a map, or something. this.cvp = new OrcColumnVectorProducer(metadataCache, orcCache, cache, conf, cacheMetrics,