FAQ
Author: prasanthj
Date: Thu Apr 16 06:55:37 2015
New Revision: 1674008

URL: http://svn.apache.org/r1674008
Log:
LLAP: Name IO elevator threads (Prasanth Jayachandran)

Modified:
     hive/branches/llap/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java

Modified: hive/branches/llap/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java
URL: http://svn.apache.org/viewvc/hive/branches/llap/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java?rev=1674008&r1=1674007&r2=1674008&view=diff
==============================================================================
--- hive/branches/llap/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java (original)
+++ hive/branches/llap/llap-server/src/java/org/apache/hadoop/hive/llap/io/api/impl/LlapIoImpl.java Thu Apr 16 06:55:37 2015
@@ -53,6 +53,7 @@ import org.apache.hadoop.metrics2.util.M

  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<VectorizedRowBatch> {
    public static final Log LOG = LogFactory.getLog(LlapIoImpl.class);
@@ -106,7 +107,8 @@ public class LlapIoImpl implements LlapI
      }
      // 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,

Search Discussions

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupcommits @
categorieshive, hadoop
postedApr 16, '15 at 6:55a
activeApr 16, '15 at 6:55a
posts1
users1
websitehive.apache.org

1 user in discussion

Prasanthj: 1 post

People

Translate

site design / logo © 2022 Grokbase