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

Log if ipc backoff is enabled in CallQueueManager

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 3.1.1
    • Fix Version/s: 3.2.0
    • Component/s: None
    • Labels:
      None
    • Target Version/s:
    • Hadoop Flags:
      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

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

              Dates

              • Created:
                Updated:
                Resolved: