Uploaded image for project: 'Hadoop Common'
  1. Hadoop Common
  2. HADOOP-15742

Log if ipc backoff is enabled in CallQueueManager

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 3.1.1
    • 3.2.0
    • None
    • None
    • Reviewed

    Description

      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);
        }
      

      Attachments

        1. HADOOP-15742.003.patch
          1 kB
          Ryan Wu
        2. HADOOP-15742.002.patch
          1 kB
          Ryan Wu
        3. HADOOP-15742.001.patch
          0.9 kB
          Ryan Wu

        Activity

          People

            jianliang.wu Ryan Wu
            linyiqun Yiqun Lin
            Votes:
            0 Vote for this issue
            Watchers:
            7 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: