[jira] [Updated] (HADOOP-15742) Log if ipc backoff is enabled in CallQueueManager
[ https://issues.apache.org/jira/browse/HADOOP-15742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yiqun Lin updated HADOOP-15742: --- Resolution: Fixed Hadoop Flags: Reviewed Fix Version/s: 3.2.0 Status: Resolved (was: Patch Available) Committed this to trunk. Thanks [~jianliang.wu] for the contribution and also thanks additional reviews, :). > Log if 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 >Priority: Minor > Fix For: 3.2.0 > > Attachments: HADOOP-15742.001.patch, HADOOP-15742.002.patch, > HADOOP-15742.003.patch > > > 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. > {code:java} > public CallQueueManager(Class> backingClass, > Class schedulerClass, > boolean clientBackOffEnabled, int maxQueueSize, String namespace, > Configuration conf) { > int priorityLevels = parseNumLevels(namespace, conf); > this.scheduler = createScheduler(schedulerClass, priorityLevels, > namespace, conf); > BlockingQueue bq = createCallQueueInstance(backingClass, > priorityLevels, maxQueueSize, namespace, conf); > this.clientBackOffEnabled = clientBackOffEnabled; > this.putRef = new AtomicReference>(bq); > this.takeRef = new AtomicReference>(bq); > LOG.info("Using callQueue: " + backingClass + " queueCapacity: " + > maxQueueSize + " scheduler: " + schedulerClass); > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org
[jira] [Updated] (HADOOP-15742) Log if ipc backoff is enabled in CallQueueManager
[ https://issues.apache.org/jira/browse/HADOOP-15742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Wu updated HADOOP-15742: - Attachment: HADOOP-15742.003.patch > Log if 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 >Priority: Minor > Attachments: HADOOP-15742.001.patch, HADOOP-15742.002.patch, > HADOOP-15742.003.patch > > > 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. > {code:java} > public CallQueueManager(Class> backingClass, > Class schedulerClass, > boolean clientBackOffEnabled, int maxQueueSize, String namespace, > Configuration conf) { > int priorityLevels = parseNumLevels(namespace, conf); > this.scheduler = createScheduler(schedulerClass, priorityLevels, > namespace, conf); > BlockingQueue bq = createCallQueueInstance(backingClass, > priorityLevels, maxQueueSize, namespace, conf); > this.clientBackOffEnabled = clientBackOffEnabled; > this.putRef = new AtomicReference>(bq); > this.takeRef = new AtomicReference>(bq); > LOG.info("Using callQueue: " + backingClass + " queueCapacity: " + > maxQueueSize + " scheduler: " + schedulerClass); > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org
[jira] [Updated] (HADOOP-15742) Log if ipc backoff is enabled in CallQueueManager
[ https://issues.apache.org/jira/browse/HADOOP-15742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Wu updated HADOOP-15742: - Attachment: HADOOP-15742.002.patch > Log if 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 >Priority: Minor > Attachments: HADOOP-15742.001.patch, HADOOP-15742.002.patch > > > 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. > {code:java} > public CallQueueManager(Class> backingClass, > Class schedulerClass, > boolean clientBackOffEnabled, int maxQueueSize, String namespace, > Configuration conf) { > int priorityLevels = parseNumLevels(namespace, conf); > this.scheduler = createScheduler(schedulerClass, priorityLevels, > namespace, conf); > BlockingQueue bq = createCallQueueInstance(backingClass, > priorityLevels, maxQueueSize, namespace, conf); > this.clientBackOffEnabled = clientBackOffEnabled; > this.putRef = new AtomicReference>(bq); > this.takeRef = new AtomicReference>(bq); > LOG.info("Using callQueue: " + backingClass + " queueCapacity: " + > maxQueueSize + " scheduler: " + schedulerClass); > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org
[jira] [Updated] (HADOOP-15742) Log if ipc backoff is enabled in CallQueueManager
[ https://issues.apache.org/jira/browse/HADOOP-15742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yiqun Lin updated HADOOP-15742: --- Status: Patch Available (was: Open) > Log if 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 >Priority: Minor > Attachments: HADOOP-15742.001.patch > > > 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. > {code:java} > public CallQueueManager(Class> backingClass, > Class schedulerClass, > boolean clientBackOffEnabled, int maxQueueSize, String namespace, > Configuration conf) { > int priorityLevels = parseNumLevels(namespace, conf); > this.scheduler = createScheduler(schedulerClass, priorityLevels, > namespace, conf); > BlockingQueue bq = createCallQueueInstance(backingClass, > priorityLevels, maxQueueSize, namespace, conf); > this.clientBackOffEnabled = clientBackOffEnabled; > this.putRef = new AtomicReference>(bq); > this.takeRef = new AtomicReference>(bq); > LOG.info("Using callQueue: " + backingClass + " queueCapacity: " + > maxQueueSize + " scheduler: " + schedulerClass); > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org
[jira] [Updated] (HADOOP-15742) Log if ipc backoff is enabled in CallQueueManager
[ https://issues.apache.org/jira/browse/HADOOP-15742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Wu updated HADOOP-15742: - Attachment: HADOOP-15742.001.patch > Log if 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 >Priority: Minor > Attachments: HADOOP-15742.001.patch > > > 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. > {code:java} > public CallQueueManager(Class> backingClass, > Class schedulerClass, > boolean clientBackOffEnabled, int maxQueueSize, String namespace, > Configuration conf) { > int priorityLevels = parseNumLevels(namespace, conf); > this.scheduler = createScheduler(schedulerClass, priorityLevels, > namespace, conf); > BlockingQueue bq = createCallQueueInstance(backingClass, > priorityLevels, maxQueueSize, namespace, conf); > this.clientBackOffEnabled = clientBackOffEnabled; > this.putRef = new AtomicReference>(bq); > this.takeRef = new AtomicReference>(bq); > LOG.info("Using callQueue: " + backingClass + " queueCapacity: " + > maxQueueSize + " scheduler: " + schedulerClass); > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org
[jira] [Updated] (HADOOP-15742) Log if ipc backoff is enabled in CallQueueManager
[ https://issues.apache.org/jira/browse/HADOOP-15742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yiqun Lin updated HADOOP-15742: --- Summary: Log if ipc backoff is enabled in CallQueueManager (was: Log if the ipc backoff is enabled in CallQueueManager) > Log if 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 >Priority: Minor > > 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. > {code:java} > public CallQueueManager(Class> backingClass, > Class schedulerClass, > boolean clientBackOffEnabled, int maxQueueSize, String namespace, > Configuration conf) { > int priorityLevels = parseNumLevels(namespace, conf); > this.scheduler = createScheduler(schedulerClass, priorityLevels, > namespace, conf); > BlockingQueue bq = createCallQueueInstance(backingClass, > priorityLevels, maxQueueSize, namespace, conf); > this.clientBackOffEnabled = clientBackOffEnabled; > this.putRef = new AtomicReference>(bq); > this.takeRef = new AtomicReference>(bq); > LOG.info("Using callQueue: " + backingClass + " queueCapacity: " + > maxQueueSize + " scheduler: " + schedulerClass); > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005) - To unsubscribe, e-mail: common-issues-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-issues-h...@hadoop.apache.org