hadoop-common-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yiqun Lin (JIRA)" <j...@apache.org>
Subject [jira] [Created] (HADOOP-15742) Log if the ipc backoff is enabled in CallQueueManager
Date Tue, 11 Sep 2018 08:05:00 GMT
Yiqun Lin created HADOOP-15742:

             Summary: Log if the ipc backoff is enabled in CallQueueManager
                 Key: HADOOP-15742
                 URL: https://issues.apache.org/jira/browse/HADOOP-15742
             Project: Hadoop Common
          Issue Type: Improvement
    Affects Versions: 3.1.1
            Reporter: Yiqun Lin
            Assignee: Ryan Wu

Currently we don't log the info of ipc backoff. It will look good to print this as well so
that makes users know if we enable this.
  public CallQueueManager(Class<? extends BlockingQueue<E>> backingClass,
                          Class<? extends RpcScheduler> schedulerClass,
      boolean clientBackOffEnabled, int maxQueueSize, String namespace,
      Configuration conf) {
    int priorityLevels = parseNumLevels(namespace, conf);
    this.scheduler = createScheduler(schedulerClass, priorityLevels,
        namespace, conf);
    BlockingQueue<E> bq = createCallQueueInstance(backingClass,
        priorityLevels, maxQueueSize, namespace, conf);
    this.clientBackOffEnabled = clientBackOffEnabled;
    this.putRef = new AtomicReference<BlockingQueue<E>>(bq);
    this.takeRef = new AtomicReference<BlockingQueue<E>>(bq);
    LOG.info("Using callQueue: " + backingClass + " queueCapacity: " +
        maxQueueSize + " scheduler: " + schedulerClass);

This message was sent by Atlassian JIRA

To unsubscribe, e-mail: common-dev-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-dev-help@hadoop.apache.org

View raw message